@Test public void abortStreamAfterClientHalfCloseShouldCallClose() { Status status = Status.INTERNAL.withCause(new Throwable()); stream().inboundDataReceived(new EmptyByteBuf(UnpooledByteBufAllocator.DEFAULT), true); assertTrue(stream().canSend()); verify(serverListener).halfClosed(); stream().abortStream(status, true); verify(serverListener).closed(same(status)); verifyNoMoreInteractions(serverListener); assertTrue(stream().isClosed()); }
void inboundDataReceived(ByteBuf frame, boolean endOfStream) { super.inboundDataReceived(new NettyReadableBuffer(frame.retain()), endOfStream); }
NettyServerStream extends AbstractServerStream<Integer> { void inboundDataReceived(ByteBuf frame, boolean endOfStream) { super.inboundDataReceived(new NettyReadableBuffer(frame.retain()), endOfStream); } }
NettyServerStream extends AbstractServerStream<Integer> { void inboundDataReceived(ByteBuf frame, boolean endOfStream) { super.inboundDataReceived(new NettyReadableBuffer(frame.retain()), endOfStream); } NettyServerStream(Channel channel, Http2Stream http2Stream, NettyServerHandler handler,
                    int maxMessageSize); }
NettyServerStream extends AbstractServerStream<Integer> { void inboundDataReceived(ByteBuf frame, boolean endOfStream) { super.inboundDataReceived(new NettyReadableBuffer(frame.retain()), endOfStream); } NettyServerStream(Channel channel, Http2Stream http2Stream, NettyServerHandler handler,
                    int maxMessageSize); @Override Integer id(); @Override void request(final int numMessages); @Override void cancel(Status status); @Override Attributes attributes(); }
NettyServerStream extends AbstractServerStream<Integer> { void inboundDataReceived(ByteBuf frame, boolean endOfStream) { super.inboundDataReceived(new NettyReadableBuffer(frame.retain()), endOfStream); } NettyServerStream(Channel channel, Http2Stream http2Stream, NettyServerHandler handler,
                    int maxMessageSize); @Override Integer id(); @Override void request(final int numMessages); @Override void cancel(Status status); @Override Attributes attributes();  }