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

Class BiDiStream.Factory<ReqT,RespT>

java.lang.Object

io.deephaven.web.client.api.barrage.stream.BiDiStream.Factory<ReqT,RespT>

Enclosing class:

BiDiStream<Req,Resp>

public static class BiDiStream.Factory<ReqT,RespT>
extends Object

Constructor Summary

Constructors

Constructor	Description
Factory(boolean supportsClientStreaming, IntSupplier nextIntTicket)

Method Summary

Modifier and Type	Method	Description
<NoopT> BiDiStream<ReqT,RespT>	create(BiDiStream.BiDiStreamFactory<ReqT,RespT> bidirectionalStream, BiDiStream.OpenStreamFactory<ReqT,RespT> openEmulatedStream, BiDiStream.NextStreamMessageFactory<ReqT,NoopT> nextEmulatedStream)

Methods inherited from class java.lang.Object

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

Constructor Details

Factory

public Factory(boolean supportsClientStreaming,
 IntSupplier nextIntTicket)

Method Details

create

public <NoopT> BiDiStream<ReqT,RespT> create(BiDiStream.BiDiStreamFactory<ReqT,RespT> bidirectionalStream,
 BiDiStream.OpenStreamFactory<ReqT,RespT> openEmulatedStream,
 BiDiStream.NextStreamMessageFactory<ReqT,NoopT> nextEmulatedStream)