Package io.grpc.servlet.web.websocket

Class AbstractWebsocketStreamImpl

java.lang.Object
io.grpc.internal.AbstractStream
io.grpc.internal.AbstractServerStream
io.grpc.servlet.web.websocket.AbstractWebsocketStreamImpl
All Implemented Interfaces:
io.grpc.internal.MessageFramer.Sink, io.grpc.internal.ServerStream, io.grpc.internal.Stream
Direct Known Subclasses:
MultiplexedWebsocketStreamImpl, WebsocketStreamImpl
public abstract class AbstractWebsocketStreamImpl extends io.grpc.internal.AbstractServerStream

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    final class 
    AbstractWebsocketStreamImpl.WebsocketTransportState
     

    Nested classes/interfaces inherited from class io.grpc.internal.AbstractServerStream

    io.grpc.internal.AbstractServerStream.Sink, io.grpc.internal.AbstractServerStream.TransportState

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected final io.grpc.Attributes
    attributes
     
    protected final io.grpc.InternalLogId
    logId
     
    protected final io.grpc.internal.AbstractServerStream.TransportState
    transportState
     
    protected final jakarta.websocket.Session
    websocketSession
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    AbstractWebsocketStreamImpl(io.grpc.internal.WritableBufferAllocator bufferAllocator, io.grpc.internal.StatsTraceContext statsTraceCtx, int maxInboundMessageSize, jakarta.websocket.Session websocketSession, io.grpc.InternalLogId logId, io.grpc.Attributes attributes, Logger logger)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    cancelSink(io.grpc.Status status)
     
    void
    createStream(io.grpc.internal.ServerTransportListener transportListener, String methodName, io.grpc.Metadata headers)
     
    io.grpc.Attributes
    getAttributes()
     
    void
    inboundDataReceived(io.grpc.internal.ReadableBuffer message, boolean endOfStream)
     
    int
    streamId()
     
    void
    transportReportStatus(io.grpc.Status status)
     
    io.grpc.internal.AbstractServerStream.TransportState
    transportState()
     
    protected static void
    writeAsciiHeadersToMessage(byte[][] serializedHeaders, ByteBuffer message)
     

    Methods inherited from class io.grpc.internal.AbstractServerStream

    abstractServerStreamSink, cancel, close, deliverFrame, framer, getAuthority, isReady, setDecompressor, setListener, setOnReadyThreshold, statsTraceContext, writeHeaders

    Methods inherited from class io.grpc.internal.AbstractStream

    endOfMessages, flush, onSendingBytes, optimizeForDirectExecutor, request, setCompressor, setMessageCompression, writeMessage

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface io.grpc.internal.Stream

    flush, optimizeForDirectExecutor, request, setCompressor, setMessageCompression, writeMessage

  • Field Details

    • transportState

      protected final io.grpc.internal.AbstractServerStream.TransportState transportState

    • websocketSession

      protected final jakarta.websocket.Session websocketSession

    • logId

      protected final io.grpc.InternalLogId logId

    • attributes

      protected final io.grpc.Attributes attributes

  • Constructor Details

    • AbstractWebsocketStreamImpl

      public AbstractWebsocketStreamImpl(io.grpc.internal.WritableBufferAllocator bufferAllocator, io.grpc.internal.StatsTraceContext statsTraceCtx, int maxInboundMessageSize, jakarta.websocket.Session websocketSession, io.grpc.InternalLogId logId, io.grpc.Attributes attributes, Logger logger)

  • Method Details

    • writeAsciiHeadersToMessage

      protected static void writeAsciiHeadersToMessage(byte[][] serializedHeaders, ByteBuffer message)

    • streamId

      public int streamId()

    • getAttributes

      public io.grpc.Attributes getAttributes()
      Specified by:
      getAttributes in interface io.grpc.internal.ServerStream
      Overrides:
      getAttributes in class io.grpc.internal.AbstractServerStream

    • createStream

      public void createStream(io.grpc.internal.ServerTransportListener transportListener, String methodName, io.grpc.Metadata headers)

    • inboundDataReceived

      public void inboundDataReceived(io.grpc.internal.ReadableBuffer message, boolean endOfStream)

    • transportReportStatus

      public void transportReportStatus(io.grpc.Status status)

    • transportState

      public io.grpc.internal.AbstractServerStream.TransportState transportState()
      Specified by:
      transportState in class io.grpc.internal.AbstractServerStream

    • cancelSink

      protected void cancelSink(io.grpc.Status status)