Examples of org.atmosphere.wasync.Socket.fire()

org.atmosphere.wasync.Socket.fire()
Send data to the remote Server. The object will first be delivered to the set of {@link Encoder}, and then send to the server. The server's response will be delivered to the set of defined {@link Function} using the opened {@link Transport}, e.g for {@link Request.TRANSPORT#WEBSOCKET}, the same connection will be re-used and, for others transports, the suspended connection. @param data object to send @return a {@link Future} @throws IOException


        }).open(request.build());


        latch.await(5, TimeUnit.SECONDS);


        socket.fire("Yo");


        ioLatch.await(5, TimeUnit.SECONDS);


        assertNotNull(response2.get());
        assertEquals(response2.get().getClass(), IOException.class);

View Full Code Here


            }).open(request.build());
        } catch (IOException ex) {
            ioException = ex;
        }
        socket.fire("echo");
        latch.await(5, TimeUnit.SECONDS);


        assertEquals(response.get().getClass(), ConnectException.class);
        assertTrue(IOException.class.isAssignableFrom(response2.get().getClass()));
        assertTrue(IOException.class.isAssignableFrom(ioException.getClass()));

View Full Code Here

            public void on(String t) {
                b.get().append(t);
            }
        }).open(clientRequest.build());


        socket.fire("PING");
        flatch.await(5, TimeUnit.SECONDS);


        server.stop();


        elatch.await(5, TimeUnit.SECONDS);

View Full Code Here

        }).on(Event.REOPENED, new Function<String>() {
            @Override
            public void on(String t) {
                b.get().append(t);
                try {
                    socket.fire("PONG");
                } catch (IOException e) {
                    e.printStackTrace();
                }
                latch.countDown();
            }

View Full Code Here

            public void on(String t) {
                b.get().append(t);
            }
        }).open(clientRequest.build());


        socket.fire("PING");
        latch.await(10, TimeUnit.SECONDS);
        flatch.await(10, TimeUnit.SECONDS);


        server.stop();

View Full Code Here

            }
        }).open(request.build());


        suspendedLatch.await(5, TimeUnit.SECONDS);


        socket.fire(binaryEcho).get();


        latch.await(10, TimeUnit.SECONDS);


        assertEquals(hasEchoReplied.get(), true);
    }

View Full Code Here

            }
        }).open(request.build());


        suspendedLatch.await(5, TimeUnit.SECONDS);


        socket.fire("ECHO1");
        socket.fire("ECHO2");
        socket.fire("ECHO3");
        socket.fire("ECHO4");
        socket.fire("ECHO5");

View Full Code Here

        }).open(request.build());


        suspendedLatch.await(5, TimeUnit.SECONDS);


        socket.fire("ECHO1");
        socket.fire("ECHO2");
        socket.fire("ECHO3");
        socket.fire("ECHO4");
        socket.fire("ECHO5");


        latch.await(10, TimeUnit.SECONDS);

View Full Code Here


        suspendedLatch.await(5, TimeUnit.SECONDS);


        socket.fire("ECHO1");
        socket.fire("ECHO2");
        socket.fire("ECHO3");
        socket.fire("ECHO4");
        socket.fire("ECHO5");


        latch.await(10, TimeUnit.SECONDS);

View Full Code Here

        suspendedLatch.await(5, TimeUnit.SECONDS);


        socket.fire("ECHO1");
        socket.fire("ECHO2");
        socket.fire("ECHO3");
        socket.fire("ECHO4");
        socket.fire("ECHO5");


        latch.await(10, TimeUnit.SECONDS);


        assertEquals(response.get().size(), 5);

View Full Code Here

0 1

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.