Package org.redisson.rx

Interface CommandRxExecutor

All Superinterfaces:

CommandAsyncExecutor

All Known Implementing Classes:

CommandRxBatchService, CommandRxService

public interface CommandRxExecutor
extends CommandAsyncExecutor

Author:

Nikita Koksharov

Method Summary

Modifier and Type	Method	Description
<R> io.reactivex.rxjava3.core.Flowable<R>	flowable(Callable<RFuture<R>> supplier)

Methods inherited from interface org.redisson.command.CommandAsyncExecutor

convertException, encode, encodeMapKey, encodeMapValue, evalReadAsync, evalReadAsync, evalReadAsync, evalWriteAllAsync, evalWriteAsync, evalWriteAsync, get, getConnectionManager, getInterrupted, getObjectBuilder, pollFromAnyAsync, readAllAsync, readAllAsync, readAllAsync, readAllAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readBatchedAsync, readRandomAsync, readRandomAsync, syncSubscription, syncSubscriptionInterrupted, writeAllAsync, writeAllAsync, writeAllAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeBatchedAsync

Method Detail

flowable

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