testEndOfInputWhenChannelIsClosedwhenWrite() — netty Function Reference

Source Code

handler/src/test/java/io/netty/handler/stream/ChunkedWriteHandlerTest.java lines 574–621

    @Test
    public void testEndOfInputWhenChannelIsClosedwhenWrite() {
        ChunkedInput<ByteBuf> input = new ChunkedInput<ByteBuf>() {

            @Override
            public boolean isEndOfInput() {
                return true;
            }

            @Override
            public void close() {
            }

            @Deprecated
            @Override
            public ByteBuf readChunk(ChannelHandlerContext ctx) {
                return null;
            }

            @Override
            public ByteBuf readChunk(ByteBufAllocator allocator) {
                return null;
            }

            @Override
            public long length() {
                return -1;
            }

            @Override
            public long progress() {
                return 1;
            }
        };

        EmbeddedChannel ch = new EmbeddedChannel(new ChannelOutboundHandlerAdapter() {
            @Override
            public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
                ReferenceCountUtil.release(msg);
                // Calling close so we will drop all queued messages in the ChunkedWriteHandler.
                ctx.close();
                promise.setSuccess();
            }
        }, new ChunkedWriteHandler());

        ch.writeAndFlush(input).syncUninterruptibly();
        assertFalse(ch.finishAndReleaseAll());
    }