Package com.daml.ledger.rxjava.util

Class ClientPublisherFlowable

java.lang.Object

com.daml.ledger.rxjava.util.ClientPublisherFlowable

public class ClientPublisherFlowable
extends java.lang.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 java.util.function.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 Detail

ClientPublisherFlowable

public ClientPublisherFlowable()

Method Detail

create

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