Package io.undertow.server.handlers.cache

Class ResponseCachingStreamSinkConduit

java.lang.Object
org.xnio.conduits.AbstractConduit<D>
org.xnio.conduits.AbstractSinkConduit<D>
org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>
io.undertow.server.handlers.cache.ResponseCachingStreamSinkConduit
All Implemented Interfaces:
org.xnio.conduits.Conduit, org.xnio.conduits.SinkConduit, org.xnio.conduits.StreamSinkConduit
public class ResponseCachingStreamSinkConduit extends org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>
Author:
Stuart Douglas

  • Field Summary

    Fields inherited from class org.xnio.conduits.AbstractConduit

    next

  • Constructor Summary

    Constructors
    Constructor
    Description
    ResponseCachingStreamSinkConduit(org.xnio.conduits.StreamSinkConduit next, DirectBufferCache.CacheEntry cacheEntry, long length)
    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)
     
    void
    truncateWrites()
     
    int
    write(ByteBuffer src)
     
    long
    write(ByteBuffer[] srcs, int offs, int len)
     
    int
    writeFinal(ByteBuffer src)
     
    long
    writeFinal(ByteBuffer[] srcs, int offset, int length)
     

    Methods inherited from class org.xnio.conduits.AbstractSinkConduit

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

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

    getWorker

    Methods inherited from interface org.xnio.conduits.SinkConduit

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

  • Constructor Details

    • ResponseCachingStreamSinkConduit

      public ResponseCachingStreamSinkConduit(org.xnio.conduits.StreamSinkConduit next, DirectBufferCache.CacheEntry cacheEntry, long length)
      Construct a new instance.
      Parameters:
      next - the delegate conduit to set
      cacheEntry -
      length -

  • Method Details

    • transferFrom

      public long transferFrom(FileChannel src, long position, long count) throws IOException
      Specified by:
      transferFrom in interface org.xnio.conduits.StreamSinkConduit
      Overrides:
      transferFrom in class org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>
      Throws:
      IOException

    • transferFrom

      public long transferFrom(org.xnio.channels.StreamSourceChannel source, long count, ByteBuffer throughBuffer) throws IOException
      Specified by:
      transferFrom in interface org.xnio.conduits.StreamSinkConduit
      Overrides:
      transferFrom in class org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>
      Throws:
      IOException

    • write

      public int write(ByteBuffer src) throws IOException
      Specified by:
      write in interface org.xnio.conduits.StreamSinkConduit
      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
      Specified by:
      write in interface org.xnio.conduits.StreamSinkConduit
      Overrides:
      write in class org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>
      Throws:
      IOException

    • terminateWrites

      public void terminateWrites() throws IOException
      Specified by:
      terminateWrites in interface org.xnio.conduits.SinkConduit
      Overrides:
      terminateWrites in class org.xnio.conduits.AbstractSinkConduit<org.xnio.conduits.StreamSinkConduit>
      Throws:
      IOException

    • truncateWrites

      public void truncateWrites() throws IOException
      Specified by:
      truncateWrites in interface org.xnio.conduits.SinkConduit
      Overrides:
      truncateWrites in class org.xnio.conduits.AbstractSinkConduit<org.xnio.conduits.StreamSinkConduit>
      Throws:
      IOException

    • writeFinal

      public long writeFinal(ByteBuffer[] srcs, int offset, int length) throws IOException
      Specified by:
      writeFinal in interface org.xnio.conduits.StreamSinkConduit
      Overrides:
      writeFinal in class org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>
      Throws:
      IOException

    • writeFinal

      public int writeFinal(ByteBuffer src) throws IOException
      Specified by:
      writeFinal in interface org.xnio.conduits.StreamSinkConduit
      Overrides:
      writeFinal in class org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>
      Throws:
      IOException