static <R> io.reactivex.Flowable<LedgerViewFlowable.LedgerView<R>> |
LedgerViewFlowable.of(io.reactivex.Flowable<com.daml.ledger.rxjava.components.LedgerViewFlowable.SubmissionFailure> submissionFailuresCommandIds,
io.reactivex.Flowable<com.daml.ledger.rxjava.components.LedgerViewFlowable.CompletionFailure> completionFailuresCommandIds,
io.reactivex.Flowable<WorkflowEvent> workflowEvents,
io.reactivex.Flowable<CommandsAndPendingSet> commandsAndPendingsSet,
java.util.function.Function<CreatedContract,R> transform) |
static <R> io.reactivex.Flowable<LedgerViewFlowable.LedgerView<R>> |
LedgerViewFlowable.of(LedgerViewFlowable.LedgerView<R> initialLedgerView,
io.reactivex.Flowable<com.daml.ledger.rxjava.components.LedgerViewFlowable.SubmissionFailure> submissionFailures,
io.reactivex.Flowable<com.daml.ledger.rxjava.components.LedgerViewFlowable.CompletionFailure> completionFailures,
io.reactivex.Flowable<WorkflowEvent> workflowEvents,
io.reactivex.Flowable<CommandsAndPendingSet> commandsAndPendingsSet,
java.util.function.Function<CreatedContract,R> transform) |