Examples of io.undertow.websockets.core.WebSocketChannel.send()

Class io.undertow.websockets.core.WebSocketChannel

Examples of io.undertow.websockets.core.WebSocketChannel.send()

io.undertow.websockets.core.WebSocketChannel.send()
Returns a new {@link StreamSinkFrameChannel} for sending the given {@link WebSocketFrameType} with the given payload.If this method is called multiple times, subsequent {@link StreamSinkFrameChannel}'s will not be writable until all previous frames were completely written. @param type The {@link WebSocketFrameType} for which a {@link StreamSinkChannel} should be created @param payloadSize The size of the payload which will be included in the WebSocket Frame. This may be 0 if you wantto transmit no payload at all.


        for (int i = 0; i < LONG_MSG; i++) {
            longMsg.append(new Integer(i).toString().charAt(0));
        }


        StreamSinkFrameChannel sendChannel = clientChannel.send(WebSocketFrameType.TEXT, LONG_MSG);
        new StringWriteChannelListener(longMsg.toString()).setup(sendChannel);


        latch.await(10, TimeUnit.SECONDS);
        Assert.assertEquals(longMsg.toString(), result.get());
        clientChannel.sendClose();

View Full Code Here


        for (int i = 0; i < LONG_MSG; i++) {
            longMsg.append(new Integer(i).toString().charAt(0));
        }


        StreamSinkFrameChannel sendChannel = clientChannel.send(WebSocketFrameType.TEXT, LONG_MSG);
        new StringWriteChannelListener(longMsg.toString()).setup(sendChannel);


        latch.await(10, TimeUnit.SECONDS);


        Assert.assertEquals(longMsg.toString(), result.get());

View Full Code Here

            }


        });
        clientChannel.resumeReceives();


        StreamSinkFrameChannel sendChannel = clientChannel.send(WebSocketFrameType.TEXT, "Hello, World!".length());
        new StringWriteChannelListener("Hello, World!").setup(sendChannel);


        latch.await(10, TimeUnit.SECONDS);
        Assert.assertEquals("Hello, World!", result.get());
        clientChannel.sendClose();

View Full Code Here

            }
        });
        webSocketChannel.resumeReceives();




        StreamSinkFrameChannel sendChannel = webSocketChannel.send(WebSocketFrameType.TEXT, 11);
        new StringWriteChannelListener("Hello World").setup(sendChannel);


        latch.await(10, TimeUnit.SECONDS);
        Assert.assertEquals("Hello World", result.get());
        webSocketChannel.sendClose();

View Full Code Here

            }
        });
        webSocketChannel.resumeReceives();




        StreamSinkFrameChannel sendChannel = webSocketChannel.send(WebSocketFrameType.TEXT, 11);
        new StringWriteChannelListener("Hello World").setup(sendChannel);


        latch.await(10, TimeUnit.SECONDS);
        Assert.assertEquals("Hello World", result.get());
        webSocketChannel.sendClose();

View Full Code Here

TOP

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.