Package io.grpc.servlet.web.websocket

Class WebsocketStreamImpl

java.lang.Object

io.grpc.internal.AbstractStream

io.grpc.internal.AbstractServerStream

io.grpc.servlet.web.websocket.AbstractWebsocketStreamImpl

io.grpc.servlet.web.websocket.WebsocketStreamImpl

All Implemented Interfaces:

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

public class WebsocketStreamImpl
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
WebsocketStreamImpl(io.grpc.internal.StatsTraceContext statsTraceCtx, int maxInboundMessageSize, jakarta.websocket.Session websocketSession, io.grpc.InternalLogId logId, io.grpc.Attributes attributes)

Method Summary

Modifier and Type	Method	Description
protected io.grpc.servlet.web.websocket.WebsocketStreamImpl.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, 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

Constructor Details

WebsocketStreamImpl

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

Method Details

abstractServerStreamSink

protected io.grpc.servlet.web.websocket.WebsocketStreamImpl.Sink abstractServerStreamSink()

Specified by:

abstractServerStreamSink in class io.grpc.internal.AbstractServerStream