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

Class BiDiStream<Req,Resp>

java.lang.Object

io.deephaven.web.client.api.barrage.stream.BiDiStream<Req,Resp>

public abstract class BiDiStream<Req,Resp>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	BiDiStream.BiDiStreamFactory
static class	BiDiStream.Factory<ReqT,RespT>
static interface	BiDiStream.NextStreamMessageFactory<Req>
static interface	BiDiStream.OpenStreamFactory<Req>

Constructor Summary

Constructors

Constructor	Description
BiDiStream()

Method Summary

Modifier and Type	Method	Description
static <Req, Resp> BiDiStream<Req,Resp>	bidi(Object bidirectionalStream)
abstract void	cancel()
abstract void	end()
static <Req, Resp> BiDiStream<Req,Resp>	of(BiDiStream.BiDiStreamFactory bidirectionalStream, BiDiStream.OpenStreamFactory<Req> openEmulatedStream, BiDiStream.NextStreamMessageFactory<Req> nextEmulatedStream, Req emptyReq, Supplier<BrowserHeaders> headers, IntSupplier nextIntTicket, boolean useWebsocket)
abstract void	onData(JsConsumer<Resp> handler)
abstract void	onEnd(JsConsumer<ResponseStreamWrapper.Status> handler)
abstract void	onHeaders(JsConsumer<Object> handler)
abstract void	onStatus(JsConsumer<ResponseStreamWrapper.Status> handler)
abstract void	send(Req payload)

Methods inherited from class java.lang.Object

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

Constructor Details

BiDiStream

public BiDiStream()

Method Details

of

public static <Req,
Resp> BiDiStream<Req,Resp> of(BiDiStream.BiDiStreamFactory bidirectionalStream,
 BiDiStream.OpenStreamFactory<Req> openEmulatedStream,
 BiDiStream.NextStreamMessageFactory<Req> nextEmulatedStream,
 Req emptyReq,
 Supplier<BrowserHeaders> headers,
 IntSupplier nextIntTicket,
 boolean useWebsocket)

bidi

public static <Req,
Resp> BiDiStream<Req,Resp> bidi(Object bidirectionalStream)

send

public abstract void send(Req payload)

cancel

public abstract void cancel()

end

public abstract void end()

onData

public abstract void onData(JsConsumer<Resp> handler)

onStatus

public abstract void onStatus(JsConsumer<ResponseStreamWrapper.Status> handler)

onEnd

public abstract void onEnd(JsConsumer<ResponseStreamWrapper.Status> handler)

onHeaders

public abstract void onHeaders(JsConsumer<Object> handler)