Package io.grpc.servlet.web.websocket

Class AbstractWebSocketServerStream

java.lang.Object

jakarta.websocket.Endpoint

io.grpc.servlet.web.websocket.AbstractWebSocketServerStream

Direct Known Subclasses:

MultiplexedWebSocketServerStream, WebSocketServerStream

public abstract class AbstractWebSocketServerStream
extends jakarta.websocket.Endpoint

Field Summary

Fields

Modifier and Type	Field	Description
protected final io.grpc.Attributes	attributes
protected final int	maxInboundMessageSize
protected final List<? extends io.grpc.ServerStreamTracer.Factory>	streamTracerFactories
protected final io.grpc.internal.ServerTransportListener	transportListener
protected jakarta.websocket.Session	websocketSession

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractWebSocketServerStream(io.grpc.internal.ServerTransportListener transportListener, List<? extends io.grpc.ServerStreamTracer.Factory> streamTracerFactories, int maxInboundMessageSize, io.grpc.Attributes attributes)

Method Summary

Modifier and Type	Method	Description
abstract void	onMessage(String message)
abstract void	onMessage(ByteBuffer message)
void	onOpen(jakarta.websocket.Session websocketSession, jakarta.websocket.EndpointConfig config)
protected static io.grpc.Metadata	readHeaders(ByteBuffer headerPayload)

Methods inherited from class jakarta.websocket.Endpoint

onClose, onError

Methods inherited from class java.lang.Object

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

Field Details

transportListener

protected final io.grpc.internal.ServerTransportListener transportListener

streamTracerFactories

protected final List<? extends io.grpc.ServerStreamTracer.Factory> streamTracerFactories

maxInboundMessageSize

protected final int maxInboundMessageSize

attributes

protected final io.grpc.Attributes attributes

websocketSession

protected jakarta.websocket.Session websocketSession

Constructor Details

AbstractWebSocketServerStream

protected AbstractWebSocketServerStream(io.grpc.internal.ServerTransportListener transportListener,
 List<? extends io.grpc.ServerStreamTracer.Factory> streamTracerFactories,
 int maxInboundMessageSize,
 io.grpc.Attributes attributes)

Method Details

readHeaders

protected static io.grpc.Metadata readHeaders(ByteBuffer headerPayload)

onOpen

public void onOpen(jakarta.websocket.Session websocketSession,
 jakarta.websocket.EndpointConfig config)

Specified by:

onOpen in class jakarta.websocket.Endpoint

onMessage

public abstract void onMessage(String message)

onMessage

public abstract void onMessage(ByteBuffer message)
                        throws IOException

Throws:

IOException