public class ReactiveCommandDispatcher<K,V,T> extends Object implements Observable.OnSubscribe<T>
Constructor and Description |
---|
ReactiveCommandDispatcher(RedisCommand<K,V,T> staticCommand,
StatefulConnection<K,V> connection,
boolean dissolve) |
ReactiveCommandDispatcher(Supplier<RedisCommand<K,V,T>> commandSupplier,
StatefulConnection<K,V> connection,
boolean dissolve) |
public ReactiveCommandDispatcher(RedisCommand<K,V,T> staticCommand, StatefulConnection<K,V> connection, boolean dissolve)
staticCommand
- static command, must not be nullconnection
- the connection, must not be nulldissolve
- dissolve collections into particular elementspublic ReactiveCommandDispatcher(Supplier<RedisCommand<K,V,T>> commandSupplier, StatefulConnection<K,V> connection, boolean dissolve)
commandSupplier
- command supplier, must not be nullconnection
- the connection, must not be nulldissolve
- dissolve collections into particular elementspublic void call(Subscriber<? super T> subscriber)
call
in interface Action1<Subscriber<? super T>>
Copyright © 2018 lettuce.io. All rights reserved.