List of toByteBuffers() Examples

Examples of toByteBuffers()

co.paralleluniverse.galaxy.core.Message.toByteBuffers()
The contract is: the first buffer is new. Comm can do whatever with it. The rest of the buffers point to cache buffers, so if they're not handled during the send() call (i.e. if they're queued and handled later), then they must be copied.
Note that this returns a different representation from toByteArray! @return

Examples of co.paralleluniverse.galaxy.core.Message.toByteBuffers()

@ChannelHandler.Sharable
public class MessageCodec extends OneToOneCodec {
    @Override
    protected Object encode(ChannelHandlerContext ctx, Channel channel, Object msg) throws Exception {
        final Message message = (Message) msg;
        final ByteBuffer[] buffers = message.toByteBuffers();
        return ChannelBuffers.wrappedBuffer(buffers);
    }


    @Override
    protected Object decode(ChannelHandlerContext ctx, Channel channel, Object msg) throws Exception {

View Full Code Here

Examples of co.paralleluniverse.galaxy.core.Message.toByteBuffers()

@ChannelHandler.Sharable
public class MessageCodec extends OneToOneCodec {
    @Override
    protected Object encode(ChannelHandlerContext ctx, Channel channel, Object msg) throws Exception {
        final Message message = (Message) msg;
        final ByteBuffer[] buffers = message.toByteBuffers();
        return ChannelBuffers.wrappedBuffer(buffers);
    }


    @Override
    protected Object decode(ChannelHandlerContext ctx, Channel channel, Object msg) throws Exception {

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.