Package io.grpc.servlet.web.websocket

Class AbstractWebsocketStreamImpl.WebsocketTransportState

java.lang.Object
io.grpc.internal.AbstractStream.TransportState
io.grpc.servlet.web.websocket.AbstractWebsocketStreamImpl.WebsocketTransportState
All Implemented Interfaces:
io.grpc.internal.ApplicationThreadDeframerListener.TransportExecutor, io.grpc.internal.MessageDeframer.Listener
Enclosing class:
AbstractWebsocketStreamImpl
public final class AbstractWebsocketStreamImpl.WebsocketTransportState extends io.grpc.internal.AbstractStream.TransportState

  • Field Summary

    Fields inherited from class io.grpc.internal.AbstractStream.TransportState

    DEFAULT_ONREADY_THRESHOLD

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    bytesRead(int numBytes)
     
    void
    deframeFailed(Throwable cause)
     
    void
    runOnTransportThread(Runnable r)
     

    Methods inherited from class io.grpc.internal.AbstractStream.TransportState

    closeDeframer, deframe, getStatsTraceContext, getTransportTracer, isStreamDeallocated, messagesAvailable, onSentBytes, onStreamDeallocated, requestMessagesFromDeframerForTesting, setDecompressor, setFullStreamDecompressor

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • runOnTransportThread

      public void runOnTransportThread(Runnable r)

    • bytesRead

      public void bytesRead(int numBytes)

    • deframeFailed

      public void deframeFailed(Throwable cause)