
final List<Map<String, Object>> events = new ArrayList<>();
</BUG>
while (channelBuffer.readable()) {
<BUG>final List<Map<String, Object>> buffer = processBuffer(channel, channelBuffer);

if (buffer != null) {

events.addAll(buffer);
}</BUG>
}

channelBuffer.readBytes(data);
try (final ByteArrayInputStream dataStream = new ByteArrayInputStream(data);
final InputStream in = new InflaterInputStream(dataStream)) {
final ChannelBuffer buffer = ChannelBuffers.copiedBuffer(ByteStreams.toByteArray(in));
return processCompressedDataFrames(channel, buffer);
