From 14354a6a8b1f20a350b405936d0118cea74c25ab Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Tue, 20 Nov 2018 17:36:18 +0300 Subject: [PATCH] refactoring --- .../org/redisson/api/RStreamReactive.java | 22 +++++++++---------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/redisson/src/main/java/org/redisson/api/RStreamReactive.java b/redisson/src/main/java/org/redisson/api/RStreamReactive.java index ce0501402..87b2139db 100644 --- a/redisson/src/main/java/org/redisson/api/RStreamReactive.java +++ b/redisson/src/main/java/org/redisson/api/RStreamReactive.java @@ -197,7 +197,7 @@ public interface RStreamReactive extends RExpirableReactive { * @param nameToId - Stream Message ID mapped by stream name * @return stream data mapped by key and Stream Message ID */ - Publisher>>> readGroup(String groupName, String consumerName,StreamMessageId id, Map nameToId); + Mono>>> readGroup(String groupName, String consumerName,StreamMessageId id, Map nameToId); /** * Read stream data from groupName by consumerName, starting by specified message ids for this and other streams. @@ -209,7 +209,7 @@ public interface RStreamReactive extends RExpirableReactive { * @param nameToId - Stream Message ID mapped by stream name * @return stream data mapped by key and Stream Message ID */ - Publisher>>> readGroup(String groupName, String consumerName, int count, StreamMessageId id, Map nameToId); + Mono>>> readGroup(String groupName, String consumerName, int count, StreamMessageId id, Map nameToId); /** * Read stream data from groupName by consumerName, starting by specified message ids for this and other streams. @@ -225,7 +225,7 @@ public interface RStreamReactive extends RExpirableReactive { * @param id2 - starting message id for second stream * @return stream data mapped by key and Stream Message ID */ - Publisher>>> readGroup(String groupName, String consumerName, int count, long timeout, TimeUnit unit, StreamMessageId id, String key2, StreamMessageId id2); + Mono>>> readGroup(String groupName, String consumerName, int count, long timeout, TimeUnit unit, StreamMessageId id, String key2, StreamMessageId id2); /** * Read stream data from groupName by consumerName, starting by specified message ids for this and other streams. @@ -243,7 +243,7 @@ public interface RStreamReactive extends RExpirableReactive { * @param id3 - starting message id for third stream * @return stream data mapped by key and Stream Message ID */ - Publisher>>> readGroup(String groupName, String consumerName, int count, long timeout, TimeUnit unit, StreamMessageId id, + Mono>>> readGroup(String groupName, String consumerName, int count, long timeout, TimeUnit unit, StreamMessageId id, String key2, StreamMessageId id2, String key3, StreamMessageId id3); /** @@ -258,7 +258,7 @@ public interface RStreamReactive extends RExpirableReactive { * @param nameToId - Stream Message ID mapped by stream name * @return stream data mapped by key and Stream Message ID */ - Publisher>>> readGroup(String groupName, String consumerName, long timeout, TimeUnit unit, StreamMessageId id, Map nameToId); + Mono>>> readGroup(String groupName, String consumerName, long timeout, TimeUnit unit, StreamMessageId id, Map nameToId); /** * Read stream data from groupName by consumerName, starting by specified message ids for this and other streams. @@ -270,7 +270,7 @@ public interface RStreamReactive extends RExpirableReactive { * @param id2 - starting message id for second stream * @return stream data mapped by key and Stream Message ID */ - Publisher>>> readGroup(String groupName, String consumerName, StreamMessageId id, String key2, StreamMessageId id2); + Mono>>> readGroup(String groupName, String consumerName, StreamMessageId id, String key2, StreamMessageId id2); /** * Read stream data from groupName by consumerName, starting by specified message ids for this and other streams. @@ -284,7 +284,7 @@ public interface RStreamReactive extends RExpirableReactive { * @param id3 - starting message id for third stream * @return stream data mapped by key and Stream Message ID */ - Publisher>>> readGroup(String groupName, String consumerName, StreamMessageId id, String key2, StreamMessageId id2, String key3, + Mono>>> readGroup(String groupName, String consumerName, StreamMessageId id, String key2, StreamMessageId id2, String key3, StreamMessageId id3); /** @@ -298,7 +298,7 @@ public interface RStreamReactive extends RExpirableReactive { * @param id2 - starting message id for second stream * @return stream data mapped by key and Stream Message ID */ - Publisher>>> readGroup(String groupName, String consumerName, int count, StreamMessageId id, String key2, StreamMessageId id2); + Mono>>> readGroup(String groupName, String consumerName, int count, StreamMessageId id, String key2, StreamMessageId id2); /** * Read stream data from groupName by consumerName, starting by specified message ids for this and other streams. @@ -313,7 +313,7 @@ public interface RStreamReactive extends RExpirableReactive { * @param id3 - starting message id for third stream * @return stream data mapped by key and Stream Message ID */ - Publisher>>> readGroup(String groupName, String consumerName, int count, StreamMessageId id, String key2, StreamMessageId id2, + Mono>>> readGroup(String groupName, String consumerName, int count, StreamMessageId id, String key2, StreamMessageId id2, String key3, StreamMessageId id3); /** @@ -329,7 +329,7 @@ public interface RStreamReactive extends RExpirableReactive { * @param id2 - starting message id for second stream * @return stream data mapped by key and Stream Message ID */ - Publisher>>> readGroup(String groupName, String consumerName, long timeout, TimeUnit unit, StreamMessageId id, + Mono>>> readGroup(String groupName, String consumerName, long timeout, TimeUnit unit, StreamMessageId id, String key2, StreamMessageId id2); /** @@ -347,7 +347,7 @@ public interface RStreamReactive extends RExpirableReactive { * @param id3 - starting message id for third stream * @return stream data mapped by key and Stream Message ID */ - Publisher>>> readGroup(String groupName, String consumerName, long timeout, TimeUnit unit, StreamMessageId id, + Mono>>> readGroup(String groupName, String consumerName, long timeout, TimeUnit unit, StreamMessageId id, String key2, StreamMessageId id2, String key3, StreamMessageId id3); /**