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>

Type Parameters:

Req - the request message type

Resp - the response message type

public abstract class BiDiStream<Req,Resp>
extends Object

Single interface to interact with real bidi streams, or emulate them using Open/Next methods.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	BiDiStream.BiDiStreamFactory<Req,Resp>	Represents a fully bidi capable stream.
static class	BiDiStream.Factory<ReqT,RespT>
static interface	BiDiStream.NextStreamMessageFactory<Req,NextT>	When bidi streams are not supported, this factory represents the ability to send streaming client messages to the server, and have them handled as if they were part of the original stream.
static interface	BiDiStream.OpenStreamFactory<Req,Resp>	When bidi streams are not supported, this factory represents a server-streaming call, for server messages to be delivered to the client.

Constructor Summary

Constructors

Constructor	Description
BiDiStream()

Method Summary

Modifier and Type	Method	Description
abstract void	cancel()
abstract void	end()
abstract void	onData(Consumer<Resp> handler)
abstract void	onEnd(Consumer<io.grpc.Status> handler)
abstract void	onHeaders(Consumer<Object> handler)
abstract void	onStatus(Consumer<io.grpc.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

send

public abstract void send(Req payload)

cancel

public abstract void cancel()

end

public abstract void end()

onData

public abstract void onData(Consumer<Resp> handler)

onStatus

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

onEnd

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

onHeaders

public abstract void onHeaders(Consumer<Object> handler)