java.io.Closeable
, java.lang.AutoCloseable
, java.nio.channels.Channel
, java.nio.channels.GatheringByteChannel
, java.nio.channels.InterruptibleChannel
, java.nio.channels.WritableByteChannel
, org.xnio.channels.CloseableChannel
, org.xnio.channels.Configurable
, org.xnio.channels.StreamSinkChannel
, org.xnio.channels.SuspendableWriteChannel
public abstract class DetachableStreamSinkChannel
extends java.lang.Object
implements org.xnio.channels.StreamSinkChannel
Modifier and Type | Field | Description |
---|---|---|
protected org.xnio.ChannelListener.SimpleSetter<DetachableStreamSinkChannel> |
closeSetter |
|
protected org.xnio.channels.StreamSinkChannel |
delegate |
|
protected org.xnio.ChannelListener.SimpleSetter<DetachableStreamSinkChannel> |
writeSetter |
Constructor | Description |
---|---|
DetachableStreamSinkChannel(org.xnio.channels.StreamSinkChannel delegate) |
Modifier and Type | Method | Description |
---|---|---|
void |
awaitWritable() |
|
void |
awaitWritable(long time,
java.util.concurrent.TimeUnit timeUnit) |
|
void |
close() |
|
boolean |
flush() |
|
org.xnio.ChannelListener.Setter<? extends org.xnio.channels.StreamSinkChannel> |
getCloseSetter() |
|
org.xnio.XnioIoThread |
getIoThread() |
|
<T> T |
getOption(org.xnio.Option<T> option) |
|
org.xnio.XnioWorker |
getWorker() |
|
org.xnio.ChannelListener.Setter<? extends org.xnio.channels.StreamSinkChannel> |
getWriteSetter() |
|
org.xnio.XnioExecutor |
getWriteThread() |
|
protected abstract boolean |
isFinished() |
|
boolean |
isOpen() |
|
boolean |
isWriteResumed() |
|
void |
responseDone() |
|
void |
resumeWrites() |
|
<T> T |
setOption(org.xnio.Option<T> option,
T value) |
|
void |
shutdownWrites() |
|
boolean |
supportsOption(org.xnio.Option<?> option) |
|
void |
suspendWrites() |
|
long |
transferFrom(java.nio.channels.FileChannel src,
long position,
long count) |
|
long |
transferFrom(org.xnio.channels.StreamSourceChannel source,
long count,
java.nio.ByteBuffer throughBuffer) |
|
void |
wakeupWrites() |
|
int |
write(java.nio.ByteBuffer src) |
|
long |
write(java.nio.ByteBuffer[] srcs) |
|
long |
write(java.nio.ByteBuffer[] srcs,
int offset,
int length) |
|
int |
writeFinal(java.nio.ByteBuffer src) |
|
long |
writeFinal(java.nio.ByteBuffer[] srcs) |
|
long |
writeFinal(java.nio.ByteBuffer[] srcs,
int offset,
int length) |
protected final org.xnio.channels.StreamSinkChannel delegate
protected org.xnio.ChannelListener.SimpleSetter<DetachableStreamSinkChannel> writeSetter
protected org.xnio.ChannelListener.SimpleSetter<DetachableStreamSinkChannel> closeSetter
public DetachableStreamSinkChannel(org.xnio.channels.StreamSinkChannel delegate)
protected abstract boolean isFinished()
public void suspendWrites()
suspendWrites
in interface org.xnio.channels.SuspendableWriteChannel
public boolean isWriteResumed()
isWriteResumed
in interface org.xnio.channels.SuspendableWriteChannel
public void shutdownWrites() throws java.io.IOException
shutdownWrites
in interface org.xnio.channels.SuspendableWriteChannel
java.io.IOException
public void awaitWritable() throws java.io.IOException
awaitWritable
in interface org.xnio.channels.SuspendableWriteChannel
java.io.IOException
public void awaitWritable(long time, java.util.concurrent.TimeUnit timeUnit) throws java.io.IOException
awaitWritable
in interface org.xnio.channels.SuspendableWriteChannel
java.io.IOException
public org.xnio.XnioExecutor getWriteThread()
getWriteThread
in interface org.xnio.channels.SuspendableWriteChannel
public boolean isOpen()
isOpen
in interface java.nio.channels.Channel
isOpen
in interface org.xnio.channels.SuspendableWriteChannel
public void close() throws java.io.IOException
close
in interface java.lang.AutoCloseable
close
in interface java.nio.channels.Channel
close
in interface java.io.Closeable
close
in interface org.xnio.channels.CloseableChannel
close
in interface java.nio.channels.InterruptibleChannel
close
in interface org.xnio.channels.SuspendableWriteChannel
java.io.IOException
public boolean flush() throws java.io.IOException
flush
in interface org.xnio.channels.SuspendableWriteChannel
java.io.IOException
public long transferFrom(java.nio.channels.FileChannel src, long position, long count) throws java.io.IOException
transferFrom
in interface org.xnio.channels.StreamSinkChannel
java.io.IOException
public long transferFrom(org.xnio.channels.StreamSourceChannel source, long count, java.nio.ByteBuffer throughBuffer) throws java.io.IOException
transferFrom
in interface org.xnio.channels.StreamSinkChannel
java.io.IOException
public org.xnio.ChannelListener.Setter<? extends org.xnio.channels.StreamSinkChannel> getWriteSetter()
getWriteSetter
in interface org.xnio.channels.StreamSinkChannel
getWriteSetter
in interface org.xnio.channels.SuspendableWriteChannel
public org.xnio.ChannelListener.Setter<? extends org.xnio.channels.StreamSinkChannel> getCloseSetter()
getCloseSetter
in interface org.xnio.channels.CloseableChannel
getCloseSetter
in interface org.xnio.channels.StreamSinkChannel
getCloseSetter
in interface org.xnio.channels.SuspendableWriteChannel
public org.xnio.XnioWorker getWorker()
getWorker
in interface org.xnio.channels.CloseableChannel
public org.xnio.XnioIoThread getIoThread()
getIoThread
in interface org.xnio.channels.CloseableChannel
public long write(java.nio.ByteBuffer[] srcs, int offset, int length) throws java.io.IOException
write
in interface java.nio.channels.GatheringByteChannel
java.io.IOException
public long write(java.nio.ByteBuffer[] srcs) throws java.io.IOException
write
in interface java.nio.channels.GatheringByteChannel
java.io.IOException
public int writeFinal(java.nio.ByteBuffer src) throws java.io.IOException
writeFinal
in interface org.xnio.channels.StreamSinkChannel
java.io.IOException
public long writeFinal(java.nio.ByteBuffer[] srcs, int offset, int length) throws java.io.IOException
writeFinal
in interface org.xnio.channels.StreamSinkChannel
java.io.IOException
public long writeFinal(java.nio.ByteBuffer[] srcs) throws java.io.IOException
writeFinal
in interface org.xnio.channels.StreamSinkChannel
java.io.IOException
public boolean supportsOption(org.xnio.Option<?> option)
supportsOption
in interface org.xnio.channels.Configurable
public <T> T getOption(org.xnio.Option<T> option) throws java.io.IOException
getOption
in interface org.xnio.channels.Configurable
java.io.IOException
public <T> T setOption(org.xnio.Option<T> option, T value) throws java.lang.IllegalArgumentException, java.io.IOException
setOption
in interface org.xnio.channels.Configurable
java.lang.IllegalArgumentException
java.io.IOException
public int write(java.nio.ByteBuffer src) throws java.io.IOException
write
in interface java.nio.channels.WritableByteChannel
java.io.IOException
public void resumeWrites()
resumeWrites
in interface org.xnio.channels.SuspendableWriteChannel
public void wakeupWrites()
wakeupWrites
in interface org.xnio.channels.SuspendableWriteChannel
public void responseDone()
Copyright © 2018. All rights reserved.