org.xnio.conduits.Conduit
, org.xnio.conduits.SourceConduit
, org.xnio.conduits.StreamSourceConduit
public final class EmptyStreamSourceConduit
extends java.lang.Object
implements org.xnio.conduits.StreamSourceConduit
Constructor | Description |
---|---|
EmptyStreamSourceConduit(org.xnio.XnioIoThread readThread) |
Construct a new instance.
|
Modifier and Type | Method | Description |
---|---|---|
void |
awaitReadable() |
|
void |
awaitReadable(long time,
java.util.concurrent.TimeUnit timeUnit) |
|
org.xnio.XnioIoThread |
getReadThread() |
|
org.xnio.XnioWorker |
getWorker() |
|
boolean |
isReadResumed() |
|
boolean |
isReadShutdown() |
|
int |
read(java.nio.ByteBuffer dst) |
|
long |
read(java.nio.ByteBuffer[] dsts,
int offs,
int len) |
|
void |
resumeReads() |
|
void |
setReadReadyHandler(org.xnio.conduits.ReadReadyHandler handler) |
|
void |
suspendReads() |
|
void |
terminateReads() |
|
long |
transferTo(long position,
long count,
java.nio.channels.FileChannel target) |
|
long |
transferTo(long count,
java.nio.ByteBuffer throughBuffer,
org.xnio.channels.StreamSinkChannel target) |
|
void |
wakeupReads() |
public EmptyStreamSourceConduit(org.xnio.XnioIoThread readThread)
readThread
- the read thread for this conduitpublic void setReadReadyHandler(org.xnio.conduits.ReadReadyHandler handler)
setReadReadyHandler
in interface org.xnio.conduits.SourceConduit
public long transferTo(long position, long count, java.nio.channels.FileChannel target) throws java.io.IOException
transferTo
in interface org.xnio.conduits.StreamSourceConduit
java.io.IOException
public long transferTo(long count, java.nio.ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel target) throws java.io.IOException
transferTo
in interface org.xnio.conduits.StreamSourceConduit
java.io.IOException
public int read(java.nio.ByteBuffer dst) throws java.io.IOException
read
in interface org.xnio.conduits.StreamSourceConduit
java.io.IOException
public long read(java.nio.ByteBuffer[] dsts, int offs, int len) throws java.io.IOException
read
in interface org.xnio.conduits.StreamSourceConduit
java.io.IOException
public boolean isReadShutdown()
isReadShutdown
in interface org.xnio.conduits.SourceConduit
public void resumeReads()
resumeReads
in interface org.xnio.conduits.SourceConduit
public void suspendReads()
suspendReads
in interface org.xnio.conduits.SourceConduit
public void wakeupReads()
wakeupReads
in interface org.xnio.conduits.SourceConduit
public boolean isReadResumed()
isReadResumed
in interface org.xnio.conduits.SourceConduit
public void awaitReadable() throws java.io.IOException
awaitReadable
in interface org.xnio.conduits.SourceConduit
java.io.IOException
public void awaitReadable(long time, java.util.concurrent.TimeUnit timeUnit) throws java.io.IOException
awaitReadable
in interface org.xnio.conduits.SourceConduit
java.io.IOException
public void terminateReads() throws java.io.IOException
terminateReads
in interface org.xnio.conduits.SourceConduit
java.io.IOException
public org.xnio.XnioIoThread getReadThread()
getReadThread
in interface org.xnio.conduits.SourceConduit
public org.xnio.XnioWorker getWorker()
getWorker
in interface org.xnio.conduits.Conduit
Copyright © 2018. All rights reserved.