From 6e21552fb673e6905b32f6543a225c8b172d2a07 Mon Sep 17 00:00:00 2001 From: M Sazzadul Hoque <7600764+sazzad16@users.noreply.github.com> Date: Tue, 26 Mar 2024 22:48:21 +0600 Subject: [PATCH] Rename builder --- src/main/java/redis/clients/jedis/BuilderFactory.java | 2 +- src/main/java/redis/clients/jedis/CommandObjects.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/redis/clients/jedis/BuilderFactory.java b/src/main/java/redis/clients/jedis/BuilderFactory.java index 2f9f5aa56c..83e552de83 100644 --- a/src/main/java/redis/clients/jedis/BuilderFactory.java +++ b/src/main/java/redis/clients/jedis/BuilderFactory.java @@ -1436,7 +1436,7 @@ public String toString() { } }; - public static final Builder>> STREAM_READ_RESPONSE_MAP + public static final Builder>> STREAM_READ_MAP_RESPONSE = new Builder>>() { @Override public Map> build(Object data) { diff --git a/src/main/java/redis/clients/jedis/CommandObjects.java b/src/main/java/redis/clients/jedis/CommandObjects.java index 1c56c4576c..139fa78ae8 100644 --- a/src/main/java/redis/clients/jedis/CommandObjects.java +++ b/src/main/java/redis/clients/jedis/CommandObjects.java @@ -2672,7 +2672,7 @@ public final CommandObject>> xreadAsMap( Set> entrySet = streams.entrySet(); entrySet.forEach(entry -> args.key(entry.getKey())); entrySet.forEach(entry -> args.add(entry.getValue())); - return new CommandObject<>(args, BuilderFactory.STREAM_READ_RESPONSE_MAP); + return new CommandObject<>(args, BuilderFactory.STREAM_READ_MAP_RESPONSE); } public final CommandObject>>> xreadGroup( @@ -2696,7 +2696,7 @@ public final CommandObject>> xreadGroupAsMap( Set> entrySet = streams.entrySet(); entrySet.forEach(entry -> args.key(entry.getKey())); entrySet.forEach(entry -> args.add(entry.getValue())); - return new CommandObject<>(args, BuilderFactory.STREAM_READ_RESPONSE_MAP); + return new CommandObject<>(args, BuilderFactory.STREAM_READ_MAP_RESPONSE); } public final CommandObject> xread(XReadParams xReadParams, Map.Entry... streams) {