src/main/java/com/uber/rss/decoders/StreamServerMessageDecoder.java [154:160]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                  version, clientInfo);
              ctx.close();
              logger.debug("Closed connection to client {}", clientInfo);
              return;
            }
            state = State.READ_MESSAGE_TYPE;
            return;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/uber/rss/decoders/StreamServerMessageDecoder.java [180:186]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                  version, clientInfo);
              ctx.close();
              logger.debug("Closed connection to client {}", clientInfo);
              return;
            }
            state = State.READ_MESSAGE_TYPE;
            return;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -