java.lang.Object
org.xnio.conduits.AbstractConduit<D>
org.xnio.conduits.AbstractSourceConduit<D>
org.xnio.conduits.AbstractMessageSourceConduit<D>
- All Implemented Interfaces:
Conduit
,MessageSourceConduit
,SourceConduit
public abstract class AbstractMessageSourceConduit<D extends MessageSourceConduit>
extends AbstractSourceConduit<D>
implements MessageSourceConduit
An abstract base class for filtering message source conduits.
- Author:
- David M. Lloyd
-
Field Summary
Fields inherited from class org.xnio.conduits.AbstractConduit
next
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
Construct a new instance. -
Method Summary
Modifier and TypeMethodDescriptionint
receive
(ByteBuffer dst) Receive a message.long
receive
(ByteBuffer[] dsts, int offs, int len) Receive a message.Methods inherited from class org.xnio.conduits.AbstractSourceConduit
awaitReadable, awaitReadable, getReadThread, isReadResumed, isReadShutdown, resumeReads, setReadReadyHandler, suspendReads, terminateReads, wakeupReads
Methods inherited from class org.xnio.conduits.AbstractConduit
getWorker
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.xnio.conduits.SourceConduit
awaitReadable, awaitReadable, getReadThread, isReadResumed, isReadShutdown, resumeReads, setReadReadyHandler, suspendReads, terminateReads, wakeupReads
-
Constructor Details
-
AbstractMessageSourceConduit
Construct a new instance.- Parameters:
next
- the delegate conduit to set
-
-
Method Details
-
receive
Description copied from interface:MessageSourceConduit
Receive a message.- Specified by:
receive
in interfaceMessageSourceConduit
- 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:
IOException
- if an I/O error occurs
-
receive
Description copied from interface:MessageSourceConduit
Receive a message.- Specified by:
receive
in interfaceMessageSourceConduit
offs
- the offset into the array of buffers of the first buffer to read intolen
- 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:
IOException
- if an I/O error occurs
-