Class TransportImpl

  • All Implemented Interfaces:
    Transport

    public class TransportImpl
    extends java.lang.Object
    implements Transport
    • Constructor Detail

      • TransportImpl

        public TransportImpl​(Transport core_transport)
    • Method Detail

      • read

        public long read​(java.nio.ByteBuffer[] buffers,
                         int array_offset,
                         int length)
                  throws java.io.IOException
        Description copied from interface: Transport
        Read data from the transport into the given buffers. NOTE: Works like ScatteringByteChannel.
        Specified by:
        read in interface Transport
        Parameters:
        buffers - into which bytes are to be placed
        array_offset - offset within the buffer array of the first buffer into which bytes are to be placed
        length - maximum number of buffers to be accessed
        Returns:
        number of bytes read
        Throws:
        java.io.IOException - on read error
      • write

        public long write​(java.nio.ByteBuffer[] buffers,
                          int array_offset,
                          int length)
                   throws java.io.IOException
        Description copied from interface: Transport
        Write data to the transport from the given buffers. NOTE: Works like GatheringByteChannel.
        Specified by:
        write in interface Transport
        Parameters:
        buffers - from which bytes are to be retrieved
        array_offset - offset within the buffer array of the first buffer from which bytes are to be retrieved
        length - maximum number of buffers to be accessed
        Returns:
        number of bytes written
        Throws:
        java.io.IOException - on write error
      • coreTransport

        public Transport coreTransport()
                                throws java.io.IOException
        Throws:
        java.io.IOException
      • setFilter

        public void setFilter​(TransportFilter filter)
                       throws java.io.IOException
        Specified by:
        setFilter in interface Transport
        Throws:
        java.io.IOException