Package io.undertow.conduits

Class StoredResponseStreamSinkConduit

java.lang.Object

org.xnio.conduits.AbstractConduit<D>

org.xnio.conduits.AbstractSinkConduit<D>

org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>

io.undertow.conduits.StoredResponseStreamSinkConduit

public final class StoredResponseStreamSinkConduit
extends org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>

Author:

Stuart Douglas

Field Summary

Fields

Modifier and Type	Field	Description
static AttachmentKey<byte[]>	RESPONSE

Fields inherited from class org.xnio.conduits.AbstractConduit

next

Constructor Summary

Constructors

Constructor	Description
StoredResponseStreamSinkConduit(org.xnio.conduits.StreamSinkConduit next, HttpServerExchange exchange)	Construct a new instance.

Method Summary

Modifier and Type	Method	Description
void	terminateWrites()
long	transferFrom(FileChannel src, long position, long count)
long	transferFrom(org.xnio.channels.StreamSourceChannel source, long count, ByteBuffer throughBuffer)
int	write(ByteBuffer src)
long	write(ByteBuffer[] srcs, int offs, int len)
int	writeFinal(ByteBuffer src)
long	writeFinal(ByteBuffer[] srcs, int offs, int len)

Methods inherited from class org.xnio.conduits.AbstractConduit

getWorker

Methods inherited from class org.xnio.conduits.AbstractSinkConduit

awaitWritable, awaitWritable, flush, getWriteThread, isWriteResumed, isWriteShutdown, resumeWrites, setWriteReadyHandler, suspendWrites, truncateWrites, wakeupWrites

Methods inherited from interface org.xnio.conduits.Conduit

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.SinkConduit

awaitWritable, awaitWritable, flush, getWriteThread, isWriteResumed, isWriteShutdown, resumeWrites, setWriteReadyHandler, suspendWrites, truncateWrites, wakeupWrites

Field Detail

RESPONSE

public static final AttachmentKey<byte[]> RESPONSE

Constructor Detail

StoredResponseStreamSinkConduit

public StoredResponseStreamSinkConduit(org.xnio.conduits.StreamSinkConduit next,
                                       HttpServerExchange exchange)

Construct a new instance.

Parameters:

next - the delegate conduit to set

exchange -

Method Detail

transferFrom

public long transferFrom(org.xnio.channels.StreamSourceChannel source,
                         long count,
                         ByteBuffer throughBuffer)
                  throws IOException

Overrides:

transferFrom in class org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>

Throws:

IOException

transferFrom

public long transferFrom(FileChannel src,
                         long position,
                         long count)
                  throws IOException

Overrides:

transferFrom in class org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>

Throws:

IOException

write

public int write(ByteBuffer src)
          throws IOException

Overrides:

write in class org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>

Throws:

IOException

write

public long write(ByteBuffer[] srcs,
                  int offs,
                  int len)
           throws IOException

Overrides:

write in class org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>

Throws:

IOException

writeFinal

public int writeFinal(ByteBuffer src)
               throws IOException

Overrides:

writeFinal in class org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>

Throws:

IOException

writeFinal

public long writeFinal(ByteBuffer[] srcs,
                       int offs,
                       int len)
                throws IOException

Overrides:

writeFinal in class org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>

Throws:

IOException

terminateWrites

public void terminateWrites()
                     throws IOException

Overrides:

terminateWrites in class org.xnio.conduits.AbstractSinkConduit<org.xnio.conduits.StreamSinkConduit>

Throws:

IOException