Module 

Class AbstractMessageSourceConduit<D extends MessageSourceConduit>

    • Constructor Detail

      • AbstractMessageSourceConduit

        protected AbstractMessageSourceConduit​(D next)
        Construct a new instance.
        Parameters:
        next - the delegate conduit to set
    • Method Detail

      • receive

        public int receive​(java.nio.ByteBuffer dst)
                    throws java.io.IOException
        Description copied from interface: MessageSourceConduit
        Receive a message.
        Specified by:
        receive in interface MessageSourceConduit
        Returns:
        the size of the received message, 0 if no message is available, and -1 if the message channel has reached an end-of-file condition
        Throws:
        java.io.IOException - if an I/O error occurs
      • receive

        public long receive​(java.nio.ByteBuffer[] dsts,
                            int offs,
                            int len)
                     throws java.io.IOException
        Description copied from interface: MessageSourceConduit
        Receive a message.
        Specified by:
        receive in interface MessageSourceConduit
        offs - the offset into the array of buffers of the first buffer to read into
        len - the number of buffers to fill
        Returns:
        the size of the received message, 0 if no message is available, and -1 if the message channel has reached an end-of-file condition
        Throws:
        java.io.IOException - if an I/O error occurs