Package dev.relism.flash.http2.stream

Class Http2Stream

java.lang.Object
dev.relism.flash.http2.stream.Http2Stream
All Implemented Interfaces:
Http2RequestBody.ConsumptionListener, Http2ResponseWriter.Completion, Runnable
public final class Http2Stream extends Object implements Http2ResponseWriter.Completion, Http2RequestBody.ConsumptionListener, Runnable
Per-stream request, response, decoded-header and write state.

  • Method Details

    • assembleRequest

      public Request assembleRequest(InetSocketAddress remoteAddress, SSLSocket sslSocket)

    • validateHeaders

      public void validateHeaders()

    • prepareRequestBody

      public boolean prepareRequestBody(Http2FlowController flowController, boolean endStream)

    • receiveData

      public void receiveData(byte[] source, int offset, int length, int flowControlledBytes)

    • finishRequestBody

      public void finishRequestBody()

    • validateTrailers

      public void validateTrailers()

    • resetResponse

      public Response resetResponse()

    • transition

      public void transition(Http2StreamState.Event event)

    • id

      public int id()

    • state

      public Http2StreamState state()

    • headerBlock

      public HpackHeaderBlock headerBlock()

    • trailerBlock

      public HpackHeaderBlock trailerBlock()

    • responseWriter

      public Http2ResponseWriter responseWriter()

    • responseSink

      public void responseSink(Http2Stream.ResponseSink responseSink)

    • markResponseStarted

      public void markResponseStarted()

    • responseStarted

      public boolean responseStarted()

    • markResumeTask

      public void markResumeTask()

    • beginResponseBatch

      public boolean beginResponseBatch()

    • endResponseBatch

      public void endResponseBatch()

    • responseInFlight

      public boolean responseInFlight()

    • routeScratch

      public Object routeScratch(AbstractRouter router)

    • wsRouteScratch

      public Object wsRouteScratch(AbstractWsRouter router)

    • websocketConnect

      public boolean websocketConnect()

    • markDispatched

      public void markDispatched()

    • dispatched

      public boolean dispatched()

    • cancel

      public void cancel()

    • cancelled

      public boolean cancelled()

    • touch

      public void touch()

    • idleExpired

      public boolean idleExpired(long nowNanos, long timeoutNanos)

    • sendWindow

      public int sendWindow()

    • adjustSendWindow

      public void adjustSendWindow(int delta)

    • receiveBytes

      public boolean receiveBytes(int bytes)

    • consumedReceiveBytes

      public int consumedReceiveBytes(int bytes)

    • incrementEmptyDataFrames

      public int incrementEmptyDataFrames()

    • resetEmptyDataFrames

      public void resetEmptyDataFrames()

    • consumed

      public void consumed(int flowControlledBytes) throws IOException
      Specified by:
      consumed in interface Http2RequestBody.ConsumptionListener
      Throws:
      IOException

    • responseWriteCompleted

      public void responseWriteCompleted()
      Specified by:
      responseWriteCompleted in interface Http2ResponseWriter.Completion

    • run

      public void run()
      Specified by:
      run in interface Runnable