Top Fields Constructors Methods
org.eclipse.jetty.ee10.websocket.jakarta.common.messages

public Class DecodedBinaryStreamMessageSink<T>

extends AbstractDecodedMessageSink.Stream<Decoder.BinaryStream<T>>
Class Inheritance
Imports
java.io.IOException, .InputStream, java.lang.invoke.MethodHandle, .MethodType, java.util.List, jakarta.websocket.CloseReason, .DecodeException, .Decoder, org.eclipse.jetty.ee10.websocket.jakarta.common.JakartaWebSocketFrameHandlerFactory, org.eclipse.jetty.ee10.websocket.jakarta.common.decoders.RegisteredDecoder, org.eclipse.jetty.websocket.core.CoreSession, org.eclipse.jetty.websocket.core.exception.CloseException, org.eclipse.jetty.websocket.core.messages.InputStreamMessageSink, .MessageSink

Field Summary

Inherited from org.eclipse.jetty.ee10.websocket.jakarta.common.messages.AbstractDecodedMessageSink.Stream:
_decoder

Constructor Summary

AccessConstructor and Description
public
DecodedBinaryStreamMessageSink(CoreSession session, MethodHandle methodHandle, List<RegisteredDecoder> decoders)

Method Summary

Modifier and TypeMethod and Description
pack-priv MessageSink
newMessageSink(CoreSession coreSession)

Implements abstract org.eclipse.jetty.ee10.websocket.jakarta.common.messages.AbstractDecodedMessageSink.newMessageSink.

public void
onStreamStart(InputStream stream)

Constructor Detail

DecodedBinaryStreamMessageSinkback to summary
public DecodedBinaryStreamMessageSink(CoreSession session, MethodHandle methodHandle, List<RegisteredDecoder> decoders)

Method Detail

newMessageSinkback to summary
pack-priv MessageSink newMessageSink(CoreSession coreSession) throws Exception

Implements abstract org.eclipse.jetty.ee10.websocket.jakarta.common.messages.AbstractDecodedMessageSink.newMessageSink.

Returns:MessageSink

Doc from org.eclipse.jetty.ee10.websocket.jakarta.common.messages.AbstractDecodedMessageSink.newMessageSink.

a message sink which will first decode the message then pass it to _methodHandle.

Annotations
@Override
Exceptions
Exception:

Doc from org.eclipse.jetty.ee10.websocket.jakarta.common.messages.AbstractDecodedMessageSink.newMessageSink.

for any error in creating the message sink.

onStreamStartback to summary
public void onStreamStart(InputStream stream)