public final class StreamSourceChannelWrappingConduit extends Object implements StreamSourceConduit
Constructor and Description |
---|
StreamSourceChannelWrappingConduit(StreamSourceChannel channel)
Construct a new instance.
|
Modifier and Type | Method and Description |
---|---|
void |
awaitReadable()
Block until this channel becomes readable again.
|
void |
awaitReadable(long time,
TimeUnit timeUnit)
Block until this conduit becomes readable again, or until the timeout expires.
|
XnioIoThread |
getReadThread()
Get the XNIO read thread.
|
XnioWorker |
getWorker()
Get the XNIO worker associated with this conduit.
|
boolean |
isReadResumed()
Determine whether read notifications are currently enabled.
|
boolean |
isReadShutdown()
Determine whether reads have been shut down on this conduit.
|
int |
read(ByteBuffer dst)
Read a sequence of bytes from this conduit to the given buffer.
|
long |
read(ByteBuffer[] dsts,
int offs,
int len)
Read a sequence of bytes from this conduit to the given buffers.
|
void |
resumeReads()
Indicate that the conduit's
ReadReadyHandler 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 |
suspendReads()
Indicate that calling the conduit's
ReadReadyHandler should be suspended. |
void |
terminateReads()
Indicate that no more data will be read from this conduit.
|
long |
transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target)
Transfers bytes into the given channel target.
|
long |
transferTo(long position,
long count,
FileChannel target)
Transfers bytes into the given file from this channel.
|
void |
wakeupReads()
Indicate that the conduit's
ReadReadyHandler should be invoked immediately, and then again as soon
as data can be read without blocking. |
public StreamSourceChannelWrappingConduit(StreamSourceChannel channel)
channel
- the channel to wrappublic void terminateReads() throws IOException
SourceConduit
terminateReads
in interface SourceConduit
IOException
- if there was a problempublic long transferTo(long position, long count, FileChannel target) throws IOException
StreamSourceConduit
transferTo
in interface StreamSourceConduit
position
- the position within the file from which the transfer is to begincount
- the number of bytes to be transferredtarget
- the file to write toIOException
- if an I/O error occurspublic long transferTo(long count, ByteBuffer throughBuffer, StreamSinkChannel target) throws IOException
StreamSourceConduit
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 than
count
, then the remaining data in throughBuffer
may contain data read from this channel which must
be written to target
to complete the operation.transferTo
in interface StreamSourceConduit
count
- the number of bytes to be transferredthroughBuffer
- the buffer to copy through.target
- the destination to write toIOException
- if an I/O error occurspublic int read(ByteBuffer dst) throws IOException
StreamSourceConduit
read
in interface StreamSourceConduit
SourceConduit.terminateReads()
method was previously calledIOException
- if an error occurspublic long read(ByteBuffer[] dsts, int offs, int len) throws IOException
StreamSourceConduit
read
in interface StreamSourceConduit
offs
- the offset into the buffer arraylen
- the number of buffers to fillSourceConduit.terminateReads()
method was previously calledIOException
- if an error occurspublic boolean isReadShutdown()
SourceConduit
isReadShutdown
in interface SourceConduit
true
if writes are shut down, false
otherwisepublic void resumeReads()
SourceConduit
ReadReadyHandler
should be invoked as soon as data can be read
without blocking.resumeReads
in interface SourceConduit
public void suspendReads()
SourceConduit
ReadReadyHandler
should be suspended.suspendReads
in interface SourceConduit
public void wakeupReads()
SourceConduit
ReadReadyHandler
should be invoked immediately, and then again as soon
as data can be read without blocking.wakeupReads
in interface SourceConduit
public boolean isReadResumed()
SourceConduit
isReadResumed
in interface SourceConduit
true
if read notifications are enabledpublic void awaitReadable() throws IOException
SourceConduit
awaitReadable
in interface SourceConduit
InterruptedIOException
- if the operation is interrupted; the thread's interrupt flag will be set as wellIOException
- if an I/O error occurspublic void awaitReadable(long time, TimeUnit timeUnit) throws IOException
SourceConduit
awaitReadable
in interface SourceConduit
time
- the time to waittimeUnit
- the time unitInterruptedIOException
- if the operation is interrupted; the thread's interrupt flag will be set as wellIOException
- if an I/O error occurspublic XnioIoThread getReadThread()
SourceConduit
getReadThread
in interface SourceConduit
public void setReadReadyHandler(ReadReadyHandler handler)
SourceConduit
setReadReadyHandler
in interface SourceConduit
public XnioWorker getWorker()
Conduit
Copyright © 2017 JBoss by Red Hat. All rights reserved.