Merge pull request #365 from NiteshKant/0.x

Fixes buffer management issue in ServerSentEventDecoder.

Author: NiteshKant

rxnetty/src/main/java/io/reactivex/netty/protocol/http/sse/ServerSentEventDecoder.java

@@ -196,6 +196,12 @@ protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) t
                         switch (currentFieldType) {
                             case Data:
                                 if (incompleteData.isReadable()) {
+                                    if (null != lastEventId) {
+                                        lastEventId.retain();
+                                    }
+                                    if (null != lastEventType) {
+                                        lastEventType.retain();
+                                    }
                                     out.add(ServerSentEvent.withEventIdAndType(lastEventId, lastEventType,
                                                                                incompleteData));
                                 } else {
@@ -207,6 +213,9 @@ protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) t
                                     lastEventId = incompleteData;
                                 } else {
                                     incompleteData.release();
+                                    if (null != lastEventId) {
+                                        lastEventId.release();
+                                    }
                                     lastEventId = null;
                                 }
                                 break;
@@ -215,6 +224,9 @@ protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) t
                                     lastEventType = incompleteData;
                                 } else {
                                     incompleteData.release();
+                                    if (null != lastEventType) {
+                                        lastEventType.release();
+                                    }
                                     lastEventType = null;
                                 }
                                 break;