CommandRxExecutor (Redisson 3.16.1 API)

All Superinterfaces:

CommandAsyncExecutor

All Known Implementing Classes:

CommandRxBatchService, CommandRxService
```
public interface CommandRxExecutor
extends CommandAsyncExecutor
```
Author:

Nikita Koksharov

- Method Summary
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method Description
  
  <R> io.reactivex.rxjava3.core.Flowable<R> <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(<RFuture<R>> supplier)