- java.lang.Object
-
- org.xnio.conduits.AbstractConduit<D>
-
- org.xnio.conduits.AbstractSourceConduit<D>
-
- org.xnio.conduits.AbstractStreamSourceConduit<StreamSourceConduit>
-
- org.xnio.conduits.PushBackStreamSourceConduit
-
- All Implemented Interfaces:
Conduit
,SourceConduit
,StreamSourceConduit
public final class PushBackStreamSourceConduit extends AbstractStreamSourceConduit<StreamSourceConduit> implements StreamSourceConduit
A stream source conduit which allows buffers to be "pushed back" to the head of the stream.- Author:
- David M. Lloyd
-
-
Field Summary
-
Fields inherited from class org.xnio.conduits.AbstractConduit
next
-
-
Constructor Summary
Constructors Constructor Description PushBackStreamSourceConduit(StreamSourceConduit next)
Construct a new instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
awaitReadable()
Block until this channel becomes readable again.void
awaitReadable(long time, java.util.concurrent.TimeUnit timeUnit)
Block until this conduit becomes readable again, or until the timeout expires.void
pushBack(Pooled<java.nio.ByteBuffer> pooledBuffer)
Push a buffer back to the head of the stream.int
read(java.nio.ByteBuffer dst)
Read a sequence of bytes from this conduit to the given buffer.long
read(java.nio.ByteBuffer[] dsts, int offs, int len)
Read a sequence of bytes from this conduit to the given buffers.void
resumeReads()
Indicate that the conduit'sReadReadyHandler
should be invoked as soon as data can be read without blocking.void
setReadReadyHandler(ReadReadyHandler handler)
Set the handler which should receive readiness notifications.void
terminateReads()
Indicate that no more data will be read from this conduit.long
transferTo(long position, long count, java.nio.channels.FileChannel target)
Transfers bytes into the given file from this channel.long
transferTo(long count, java.nio.ByteBuffer throughBuffer, StreamSinkChannel target)
Transfers bytes into the given channel target.-
Methods inherited from class org.xnio.conduits.AbstractSourceConduit
getReadThread, isReadResumed, isReadShutdown, suspendReads, 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
getReadThread, isReadResumed, isReadShutdown, suspendReads, wakeupReads
-
-
-
-
Constructor Detail
-
PushBackStreamSourceConduit
public PushBackStreamSourceConduit(StreamSourceConduit next)
Construct a new instance.- Parameters:
next
- the delegate conduit to set
-
-
Method Detail
-
resumeReads
public void resumeReads()
Description copied from interface:SourceConduit
Indicate that the conduit'sReadReadyHandler
should be invoked as soon as data can be read without blocking.- Specified by:
resumeReads
in interfaceSourceConduit
- Overrides:
resumeReads
in classAbstractSourceConduit<StreamSourceConduit>
-
read
public int read(java.nio.ByteBuffer dst) throws java.io.IOException
Description copied from interface:StreamSourceConduit
Read a sequence of bytes from this conduit to the given buffer.- Specified by:
read
in interfaceStreamSourceConduit
- Overrides:
read
in classAbstractStreamSourceConduit<StreamSourceConduit>
- Returns:
- the number of bytes (possibly 0) that were actually transferred, or -1 if the end of input was reached or
this conduit's
SourceConduit.terminateReads()
method was previously called - Throws:
java.io.IOException
- if an error occurs
-
read
public long read(java.nio.ByteBuffer[] dsts, int offs, int len) throws java.io.IOException
Description copied from interface:StreamSourceConduit
Read a sequence of bytes from this conduit to the given buffers.- Specified by:
read
in interfaceStreamSourceConduit
- Overrides:
read
in classAbstractStreamSourceConduit<StreamSourceConduit>
offs
- the offset into the buffer arraylen
- the number of buffers to fill- Returns:
- the number of bytes (possibly 0) that were actually transferred, or -1 if the end of input was reached or
this conduit's
SourceConduit.terminateReads()
method was previously called - Throws:
java.io.IOException
- if an error occurs
-
transferTo
public long transferTo(long position, long count, java.nio.channels.FileChannel target) throws java.io.IOException
Description copied from interface:StreamSourceConduit
Transfers bytes into the given file from this channel.- Specified by:
transferTo
in interfaceStreamSourceConduit
- Overrides:
transferTo
in classAbstractStreamSourceConduit<StreamSourceConduit>
- Parameters:
position
- the position within the file from which the transfer is to begincount
- the number of bytes to be transferredtarget
- the file to write to- Returns:
- the number of bytes (possibly 0) that were actually transferred
- Throws:
java.io.IOException
- if an I/O error occurs
-
transferTo
public long transferTo(long count, java.nio.ByteBuffer throughBuffer, StreamSinkChannel target) throws java.io.IOException
Description copied from interface:StreamSourceConduit
Transfers bytes into the given channel target. On entry,throughBuffer
will be cleared. On exit, the buffer will be flipped for emptying, and may possibly be empty or may contain data. If this method returns a value less thancount
, then the remaining data inthroughBuffer
may contain data read from this channel which must be written totarget
to complete the operation.- Specified by:
transferTo
in interfaceStreamSourceConduit
- Overrides:
transferTo
in classAbstractStreamSourceConduit<StreamSourceConduit>
- Parameters:
count
- the number of bytes to be transferredthroughBuffer
- the buffer to copy through.target
- the destination to write to- Returns:
- the number of bytes (possibly 0) that were actually transferred, or -1 if the end of input was reached
- Throws:
java.io.IOException
- if an I/O error occurs
-
awaitReadable
public void awaitReadable() throws java.io.IOException
Description copied from interface:SourceConduit
Block until this channel becomes readable again. This method may return spuriously before the channel becomes readable.- Specified by:
awaitReadable
in interfaceSourceConduit
- Overrides:
awaitReadable
in classAbstractSourceConduit<StreamSourceConduit>
- Throws:
java.io.InterruptedIOException
- if the operation is interrupted; the thread's interrupt flag will be set as welljava.io.IOException
- if an I/O error occurs
-
awaitReadable
public void awaitReadable(long time, java.util.concurrent.TimeUnit timeUnit) throws java.io.IOException
Description copied from interface:SourceConduit
Block until this conduit becomes readable again, or until the timeout expires. This method may return spuriously before the conduit becomes readable or the timeout expires.- Specified by:
awaitReadable
in interfaceSourceConduit
- Overrides:
awaitReadable
in classAbstractSourceConduit<StreamSourceConduit>
- Parameters:
time
- the time to waittimeUnit
- the time unit- Throws:
java.io.InterruptedIOException
- if the operation is interrupted; the thread's interrupt flag will be set as welljava.io.IOException
- if an I/O error occurs
-
terminateReads
public void terminateReads() throws java.io.IOException
Description copied from interface:SourceConduit
Indicate that no more data will be read from this conduit. If unread data exists, an exception may be thrown.- Specified by:
terminateReads
in interfaceSourceConduit
- Overrides:
terminateReads
in classAbstractSourceConduit<StreamSourceConduit>
- Throws:
java.io.IOException
- if there was a problem
-
setReadReadyHandler
public void setReadReadyHandler(ReadReadyHandler handler)
Description copied from interface:SourceConduit
Set the handler which should receive readiness notifications. A filter may pass this invocation on to the filter it wraps, or it may substitute itself.- Specified by:
setReadReadyHandler
in interfaceSourceConduit
- Overrides:
setReadReadyHandler
in classAbstractSourceConduit<StreamSourceConduit>
-
pushBack
public void pushBack(Pooled<java.nio.ByteBuffer> pooledBuffer)
Push a buffer back to the head of the stream. Once the buffer data is consumed, it will be released back to its original pool (if any).- Parameters:
pooledBuffer
- the buffer to push back
-
-