diff --git a/src/main/java/org/elasticsearch/transport/netty/ChannelBufferStreamInput.java b/src/main/java/org/elasticsearch/transport/netty/ChannelBufferStreamInput.java index 5f660526142..5edca5b1e07 100644 --- a/src/main/java/org/elasticsearch/transport/netty/ChannelBufferStreamInput.java +++ b/src/main/java/org/elasticsearch/transport/netty/ChannelBufferStreamInput.java @@ -120,9 +120,6 @@ public class ChannelBufferStreamInput extends StreamInput { @Override public byte readByte() throws IOException { - if (available() == 0) { - throw new EOFException(); - } return buffer.readByte(); }