RBatchReactive.getKeys added

pull/337/head
Nikita 9 years ago
parent 284c115038
commit 628d4c99c2

@ -164,13 +164,13 @@ public interface RBatchReactive {
*/ */
RScriptReactive getScript(); RScriptReactive getScript();
// /** /**
// * Returns keys operations. * Returns keys operations.
// * Each of Redis/Redisson object associated with own key * Each of Redis/Redisson object associated with own key
// * *
// * @return * @return
// */ */
// RKeysReactive getKeys(); RKeysReactive getKeys();
/** /**
* Executes all operations accumulated during Reactive methods invocations Reactivehronously. * Executes all operations accumulated during Reactive methods invocations Reactivehronously.

@ -25,6 +25,7 @@ import org.redisson.api.RBlockingQueueReactive;
import org.redisson.api.RBucketReactive; import org.redisson.api.RBucketReactive;
import org.redisson.api.RDequeReactive; import org.redisson.api.RDequeReactive;
import org.redisson.api.RHyperLogLogReactive; import org.redisson.api.RHyperLogLogReactive;
import org.redisson.api.RKeysReactive;
import org.redisson.api.RLexSortedSetReactive; import org.redisson.api.RLexSortedSetReactive;
import org.redisson.api.RListReactive; import org.redisson.api.RListReactive;
import org.redisson.api.RMapReactive; import org.redisson.api.RMapReactive;
@ -165,10 +166,10 @@ public class RedissonBatchReactive implements RBatchReactive {
return new RedissonScriptReactive(executorService); return new RedissonScriptReactive(executorService);
} }
// @Override @Override
// public RKeysReactive getKeys() { public RKeysReactive getKeys() {
// return new RedissonKeys(executorService); return new RedissonKeysReactive(executorService);
// } }
@Override @Override
public Publisher<List<?>> executeReactive() { public Publisher<List<?>> executeReactive() {

Loading…
Cancel
Save