return stream.getInputByteBuffer();
}
@Override
public void receiveEndOfStream(int streamId) throws ConnectionException {
Stream stream = getStream(streamId, true);
<BUG>if (stream != null) {
stream.receivedEndOfStream();
}</BUG>
}
@Override

return stream.getInputByteBuffer();
}
@Override
public void receiveEndOfStream(int streamId) throws ConnectionException {
Stream stream = getStream(streamId, true);
if (stream.isActive()) {
activeRemoteStreamCount--;
}
stream.receivedEndOfStream();
}
@Override
