Package io.grpc.servlet.web.websocket

Class MultiplexedWebsocketStreamImpl

java.lang.Object

io.grpc.internal.AbstractStream

io.grpc.internal.AbstractServerStream

io.grpc.servlet.web.websocket.AbstractWebsocketStreamImpl

io.grpc.servlet.web.websocket.MultiplexedWebsocketStreamImpl

All Implemented Interfaces:

io.grpc.internal.MessageFramer.Sink, io.grpc.internal.ServerStream, io.grpc.internal.Stream

public class MultiplexedWebsocketStreamImpl
extends AbstractWebsocketStreamImpl

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.servlet.web.websocket.AbstractWebsocketStreamImpl

AbstractWebsocketStreamImpl.WebsocketTransportState

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

io.grpc.internal.AbstractServerStream.TransportState

Field Summary

Fields inherited from class io.grpc.servlet.web.websocket.AbstractWebsocketStreamImpl

attributes, logId, transportState, websocketSession

Constructor Summary

Constructors

Constructor	Description
MultiplexedWebsocketStreamImpl(io.grpc.internal.StatsTraceContext statsTraceCtx, int maxInboundMessageSize, jakarta.websocket.Session websocketSession, io.grpc.InternalLogId logId, io.grpc.Attributes attributes, int streamId)

Method Summary

Modifier and Type	Method	Description
protected io.grpc.internal.AbstractServerStream.Sink	abstractServerStreamSink()

Methods inherited from class io.grpc.servlet.web.websocket.AbstractWebsocketStreamImpl

cancelSink, createStream, getAttributes, inboundDataReceived, streamId, transportReportStatus, transportState, writeAsciiHeadersToMessage

Methods inherited from class io.grpc.internal.AbstractServerStream

cancel, close, deliverFrame, framer, getAuthority, isReady, setDecompressor, setListener, 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

Constructor Details

MultiplexedWebsocketStreamImpl

public MultiplexedWebsocketStreamImpl(io.grpc.internal.StatsTraceContext statsTraceCtx,
 int maxInboundMessageSize,
 jakarta.websocket.Session websocketSession,
 io.grpc.InternalLogId logId,
 io.grpc.Attributes attributes,
 int streamId)

Method Details

abstractServerStreamSink

protected io.grpc.internal.AbstractServerStream.Sink abstractServerStreamSink()

Specified by:

abstractServerStreamSink in class io.grpc.internal.AbstractServerStream