Package com.chenshuo.muduo.example.multiplexer

Examples of com.chenshuo.muduo.example.multiplexer.MockClient.send()


        client.setId(connId);

        assertEquals("UP", m.group(2));

        // step 2
        ChannelBuffer buf = client.send("hello");
        de = (DataEvent) queue.take();
        assertEquals(EventSource.kBackend, de.source);
        assertEquals(connId, de.whichClient);
        assertEquals(buf, de.data);
        System.out.println(de.data.toString(Charset.defaultCharset()));
View Full Code Here


        client.setId(connId);

        assertEquals("UP", m.group(2));

        // step 2
        ChannelBuffer buf = client.send("hello");
        de = (DataEvent) queue.take();
        assertEquals(EventSource.kBackend, de.source);
        assertEquals(connId, de.whichClient);
        assertEquals(buf, de.data);
        System.out.println(de.data.toString(Charset.defaultCharset()));
View Full Code Here

        assertEquals(connId, de.whichClient);
        assertEquals(buf, de.data);
        System.out.println(de.data.toString(Charset.defaultCharset()));

        // step 3
        buf = client.send("World!");
        de = (DataEvent) queue.take();
        assertEquals(EventSource.kBackend, de.source);
        assertEquals(connId, de.whichClient);
        assertEquals(buf, de.data);
        System.out.println(de.data.toString(Charset.defaultCharset()));
View Full Code Here

        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < 500; ++i)
            sb.append('H');

        buf = client.send(sb.toString());

        de = (DataEvent) queue.take();
        assertEquals(EventSource.kBackend, de.source);
        assertEquals(connId, de.whichClient);
        assertEquals(buf.copy(0, 255), de.data);
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.