Package io.netty.buffer

Examples of io.netty.buffer.ByteBuf.refCnt()

519
520
521
522
523
524
525
526
527
528
529
        assertTrue(promise.cancel(false));
        ByteBuf buffer = Unpooled.buffer();
        assertEquals(1, buffer.refCnt());
        ChannelFuture future = pipeline.writeAndFlush(buffer, promise);
        assertTrue(future.isCancelled());
        assertEquals(0, buffer.refCnt());
    }

    @Test
    public void testFirstContextEmptyPipeline() throws Exception {
        ChannelPipeline pipeline = new LocalChannel().pipeline();
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
                ByteBuf byteBuf = internalBuffer();
                Assert.assertEquals(1, byteBuf.refCnt());
                in.readByte();
                // Removal from pipeline should clear internal buffer
                ctx.pipeline().remove(this);
                Assert.assertEquals(0, byteBuf.refCnt());
            }
        });
        Assert.assertTrue(channel.writeInbound(buf));
        Assert.assertTrue(channel.finish());
        Assert.assertEquals(channel.readInbound(), Unpooled.wrappedBuffer(new byte[] {'b'}));
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.