Package com.daml.ledger.rxjava.util

Class ClientPublisherFlowable

java.lang.Object

com.daml.ledger.rxjava.util.ClientPublisherFlowable

public class ClientPublisherFlowable
extends Object

Constructor Summary

Constructors

Constructor	Description
ClientPublisherFlowable()

Method Summary

Modifier and Type	Method	Description
static <Req, Resp> io.reactivex.Flowable<Resp>	create(@NonNull Req request, @NonNull BiConsumer<Req,io.grpc.stub.StreamObserver<Resp>> clientStub, @NonNull com.daml.grpc.adapter.ExecutionSequencerFactory executionSequencerFactory)

Methods inherited from class java.lang.Object

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

Constructor Details

ClientPublisherFlowable

public ClientPublisherFlowable()

Method Details

create

public static <Req,
Resp>
io.reactivex.Flowable<Resp> create(@NonNull Req request,
 @NonNull BiConsumer<Req,io.grpc.stub.StreamObserver<Resp>> clientStub,
 @NonNull com.daml.grpc.adapter.ExecutionSequencerFactory executionSequencerFactory)