Package io.deephaven.web.client.api.barrage.stream

Class ResponseStreamWrapper<T>

java.lang.Object

io.deephaven.web.client.api.event.HasEventHandling

io.deephaven.web.client.api.barrage.stream.ResponseStreamWrapper<T>

Type Parameters:

T - payload that is emitted from the stream

public class ResponseStreamWrapper<T>
extends HasEventHandling

Java wrapper to deal with the distinct ResponseStream types that are emitted. Provides strongly typed methods for cleaner Java consumption, that can be used to represent any of the structural types that are used for grpc methods.

Nested Class Summary

Nested classes/interfaces inherited from class io.deephaven.web.client.api.event.HasEventHandling

HasEventHandling.EventPair<T>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DATA_EVENT
static final String	END_EVENT
static final String	STATUS_EVENT

Fields inherited from class io.deephaven.web.client.api.event.HasEventHandling

INTERNAL_EVENT_RELEASED

Constructor Summary

Constructors

Constructor	Description
ResponseStreamWrapper(Consumer<io.grpc.stub.StreamObserver<T>> openStream)

Method Summary

Modifier and Type	Method	Description
void	cancel()
static <T> ResponseStreamWrapper<T>	of(Consumer<io.grpc.stub.StreamObserver<T>> openStream)
final void	onData(Consumer<T> handler)
final void	onEnd(Consumer<io.grpc.Status> handler)
final void	onHeaders(Consumer<Object> handler)
final void	onStatus(Consumer<io.grpc.Status> handler)

Methods inherited from class io.deephaven.web.client.api.event.HasEventHandling

addEventListener, addEventListenerOneShot, addEventListenerOneShot, failureHandled, fireCriticalEvent, fireCriticalEvent, fireEvent, fireEvent, fireEvent, hasListener, hasListeners, isSuppress, logPrefix, nextEvent, removeEventListener, suppressEvents, unsuppressEvents

Methods inherited from class java.lang.Object

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

Field Details

DATA_EVENT

public static final String DATA_EVENT

See Also:

• Constant Field Values

STATUS_EVENT

public static final String STATUS_EVENT

See Also:

• Constant Field Values

END_EVENT

public static final String END_EVENT

See Also:

• Constant Field Values

Constructor Details

ResponseStreamWrapper

public ResponseStreamWrapper(Consumer<io.grpc.stub.StreamObserver<T>> openStream)

Method Details

of

public static <T> ResponseStreamWrapper<T> of(Consumer<io.grpc.stub.StreamObserver<T>> openStream)

cancel

public void cancel()

onStatus

public final void onStatus(Consumer<io.grpc.Status> handler)

onData

public final void onData(Consumer<T> handler)

onEnd

public final void onEnd(Consumer<io.grpc.Status> handler)

onHeaders

public final void onHeaders(Consumer<Object> handler)