refactoring

redisson/src/main/java/org/redisson/client/protocol/decoder/StreamResultDecoder.java

@@ -18,10 +18,9 @@ package org.redisson.client.protocol.decoder;
 import org.redisson.api.StreamMessageId;
 import org.redisson.client.handler.State;
 
-import java.util.HashMap;
-import java.util.LinkedHashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
+import java.util.stream.Collector;
+import java.util.stream.Collectors;
 
 /**
  * 
@@ -40,6 +39,29 @@ public class StreamResultDecoder implements MultiDecoder<Object> {
     @Override
     public Object decode(List<Object> parts, State state) {
         List<List<Object>> list = (List<List<Object>>) (Object) parts;
+
+//        Map<String, Map<StreamMessageId, Map<Object, Object>>> result = list.stream().collect(
+//                Collectors.groupingBy(v -> (String) v.get(0),
+//                        Collectors.mapping(v -> (List<List<Object>>) v.get(1),
+//                            Collector.of(LinkedHashMap::new,
+//                                        (m, l) -> {
+//                                            for (List<Object> objects : l) {
+//                                                m.put((StreamMessageId) objects.get(0), (Map<Object, Object>) objects.get(1));
+//                                            }
+//                                        },
+//                                        (x, y) -> {
+//                                            x.putAll(y);
+//                                            return x;
+//                                        })
+//                        )));
+//
+//        result.values().removeAll(Collections.singleton(new HashMap()));
+//
+//        if (firstResult && !result.isEmpty()) {
+//            return result.values().iterator().next();
+//        }
+//        return result;
+
         Map<String, Map<StreamMessageId, Map<Object, Object>>> result = new HashMap<>();
         for (List<Object> entries : list) {
             List<List<Object>> streamEntries = (List<List<Object>>) entries.get(1);
@@ -47,11 +69,11 @@ public class StreamResultDecoder implements MultiDecoder<Object> {
                 String name = (String) entries.get(0);
                 Map<StreamMessageId, Map<Object, Object>> ee = new LinkedHashMap<>();
                 result.put(name, ee);
-                
+
                 for (List<Object> se : streamEntries) {
                     ee.put((StreamMessageId) se.get(0), (Map<Object, Object>) se.get(1));
                 }
-                
+
                 if (firstResult) {
                     return ee;
                 }