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

Class ResponseStreamWrapper<T>

java.lang.Object

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

Type Parameters:

T - payload that is emitted from the stream

@JsType(isNative=true,
        name="Object",
        namespace="<global>")
public class ResponseStreamWrapper<T>
extends Object

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

Modifier and Type	Class	Description
static interface	ResponseStreamWrapper.ServiceError
static interface	ResponseStreamWrapper.Status

Constructor Summary

Constructors

Constructor	Description
ResponseStreamWrapper()

Method Summary

Modifier and Type	Method	Description
void	cancel()
static <T> ResponseStreamWrapper<T>	of(Object someJsObject)
ResponseStreamWrapper<T>	on(String type, elemental2.core.Function function)
final ResponseStreamWrapper<T>	onData(JsConsumer<T> handler)
final ResponseStreamWrapper<T>	onEnd(JsConsumer<ResponseStreamWrapper.Status> handler)
final ResponseStreamWrapper<T>	onHeaders(JsConsumer<Object> handler)
final ResponseStreamWrapper<T>	onStatus(JsConsumer<ResponseStreamWrapper.Status> handler)

Methods inherited from class java.lang.Object

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

Constructor Details

ResponseStreamWrapper

public ResponseStreamWrapper()

Method Details

of

@JsOverlay
public static <T> ResponseStreamWrapper<T> of(Object someJsObject)

cancel

public void cancel()

on

public ResponseStreamWrapper<T> on(String type,
 elemental2.core.Function function)

onStatus

@JsOverlay
public final ResponseStreamWrapper<T> onStatus(JsConsumer<ResponseStreamWrapper.Status> handler)

onData

@JsOverlay
public final ResponseStreamWrapper<T> onData(JsConsumer<T> handler)

onEnd

@JsOverlay
public final ResponseStreamWrapper<T> onEnd(JsConsumer<ResponseStreamWrapper.Status> handler)

onHeaders

@JsOverlay
public final ResponseStreamWrapper<T> onHeaders(JsConsumer<Object> handler)