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, Supplier<BrowserHeaders> headers, IntSupplier nextIntTicket)

Method Summary

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

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,
 Supplier<BrowserHeaders> headers,
 IntSupplier nextIntTicket)

Method Details

create

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