Package io.netty.channel

Examples of io.netty.channel.Channel.writeAndFlush()

192
193
194
195
196
197
198
199
200
201
202
        Channel sc = sb.localAddress(0).bind().sync().channel();
        int port = ((InetSocketAddress) sc.localAddress()).getPort();

        Channel cc = cb.remoteAddress(NetUtil.LOCALHOST, port).connect().sync().channel();
        cc.writeAndFlush(frames);

        while (ch.counter < frames.writerIndex() - ignoredBytes) {
            if (sh.exception.get() != null) {
                break;
            }
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
        });

        Channel sc = sb.bind().sync().channel();
        Channel cc = cb.connect().sync().channel();
        for (String element : data) {
            cc.writeAndFlush(element);
        }

        while (ch.counter < data.length) {
            if (sh.exception.get() != null) {
                break;
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
        TestHandler ch = new TestHandler();
        cb.handler(ch);
        Channel sc = sb.bind().sync().channel();
        Channel cc = cb.connect().sync().channel();
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);
View Full Code Here
68
69
70
71
72
73
74
75
76
77
78
        cb.handler(ch);
        Channel sc = sb.bind().sync().channel();
        Channel cc = cb.connect().sync().channel();
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);

        cc.close().sync();
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
        Channel sc = sb.bind().sync().channel();
        Channel cc = cb.connect().sync().channel();

        for (int i = 0; i < data.length;) {
            int length = Math.min(random.nextInt(1024 * 64), data.length - i);
            cc.writeAndFlush(Unpooled.wrappedBuffer(data, i, length));
            i += length;
        }

        while (ch.counter < data.length) {
            if (sh.exception.get() != null) {
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
        Channel cc = cb.connect().sync().channel();
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);

        cc.close().sync();
        sc.close().sync();
View Full Code Here
105
106
107
108
109
110
111
112
113
114
115
        TestHandler ch = new TestHandler();
        cb.handler(ch);
        Channel sc = sb.bind().sync().channel();
        Channel cc = cb.connect().sync().channel();
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
        cb.handler(ch);
        Channel sc = sb.bind().sync().channel();
        Channel cc = cb.connect().sync().channel();
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);
        sh.await();
        cc.close().sync();
View Full Code Here
109
110
111
112
113
114
115
116
117
118
119
        Channel cc = cb.connect().sync().channel();
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);
        cc.writeAndFlush(Unpooled.wrappedBuffer(data)).sync();
        Thread.sleep(500);
        sh.await();
        cc.close().sync();
        sc.close().sync();
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
        Channel sc = sb.bind().sync().channel();
        Channel cc = cb.connect().sync().channel();
        for (int i = 0; i < data.length;) {
            int length = Math.min(random.nextInt(1024 * 3), data.length - i);
            cc.writeAndFlush(Unpooled.wrappedBuffer(data, i, length));
            i += length;
        }

        while (ch.counter < data.length) {
            if (sh.exception.get() != null) {
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.