Package org.redisson.rx

Class CommandRxBatchService

java.lang.Object

org.redisson.command.CommandAsyncService

org.redisson.rx.CommandRxService

org.redisson.rx.CommandRxBatchService

All Implemented Interfaces:

BatchService, CommandAsyncExecutor, CommandRxExecutor

public class CommandRxBatchService
extends CommandRxService
implements BatchService

Author:

Nikita Koksharov

Nested Class Summary

Nested classes/interfaces inherited from interface org.redisson.command.CommandAsyncExecutor

CommandAsyncExecutor.SyncMode

Method Summary

Modifier and Type	Method	Description
<V, R> RFuture<R>	async(boolean readOnlyMode, NodeSource nodeSource, Codec codec, RedisCommand<V> command, Object[] params, boolean ignoreRedirect, boolean noRetry)
protected <R> CompletableFuture<R>	createPromise()
RFuture<Void>	discardAsync()
RFuture<BatchResult<?>>	executeAsync()
<R> io.reactivex.rxjava3.core.Flowable<R>	flowable(Callable<RFuture<R>> supplier)
protected boolean	isEvalCacheActive()

Methods inherited from class org.redisson.rx.CommandRxService

copy, copy

Methods inherited from class org.redisson.command.CommandAsyncService

asyncNoScript, convertException, copy, copy, createCommandBatchService, createCommandBatchService, encode, encodeMapKey, encodeMapValue, evalAsync, evalReadAsync, evalReadAsync, evalReadAsync, evalReadAsync, evalReadAsync, evalReadBatchedAsync, evalWriteAsync, evalWriteAsync, evalWriteAsync, evalWriteBatchedAsync, evalWriteNoRetryAsync, executeAllAsync, executeAllAsync, get, get, getConnectionManager, getInterrupted, getInterrupted, getNow, getObjectBuilder, getServiceManager, handleNoSync, isEvalShaROSupported, isTrackChanges, pollFromAnyAsync, readAllAsync, readAllAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readBatchedAsync, readRandomAsync, readRandomAsync, setEvalShaROSupported, syncedEval, syncedEvalNoRetry, syncedEvalNoRetry, syncedEvalWithRetry, syncedEvalWithRetry, transfer, writeAllAsync, writeAllAsync, writeAllVoidAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeBatchedAsync

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.redisson.command.CommandAsyncExecutor

convertException, createCommandBatchService, encode, encodeMapKey, encodeMapValue, evalReadAsync, evalReadAsync, evalReadAsync, evalReadAsync, evalReadAsync, evalReadBatchedAsync, evalWriteAsync, evalWriteAsync, evalWriteAsync, evalWriteBatchedAsync, evalWriteNoRetryAsync, executeAllAsync, executeAllAsync, get, get, getConnectionManager, getInterrupted, getInterrupted, getNow, getObjectBuilder, getServiceManager, handleNoSync, isEvalShaROSupported, isTrackChanges, pollFromAnyAsync, readAllAsync, readAllAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readBatchedAsync, readRandomAsync, readRandomAsync, setEvalShaROSupported, syncedEval, syncedEvalNoRetry, syncedEvalNoRetry, syncedEvalWithRetry, syncedEvalWithRetry, transfer, writeAllAsync, writeAllAsync, writeAllVoidAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeBatchedAsync

Method Details

flowable

public <R> io.reactivex.rxjava3.core.Flowable<R> flowable(Callable<RFuture<R>> supplier)

Specified by:

flowable in interface CommandRxExecutor

Overrides:

flowable in class CommandRxService

createPromise

protected <R> CompletableFuture<R> createPromise()

Overrides:

createPromise in class CommandAsyncService

async

public <V,
R> RFuture<R> async(boolean readOnlyMode,
 NodeSource nodeSource,
 Codec codec,
 RedisCommand<V> command,
 Object[] params,
 boolean ignoreRedirect,
 boolean noRetry)

Overrides:

async in class CommandAsyncService

executeAsync

public RFuture<BatchResult<?>> executeAsync()

isEvalCacheActive

protected boolean isEvalCacheActive()

Overrides:

isEvalCacheActive in class CommandAsyncService

discardAsync

public RFuture<Void> discardAsync()