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) |
static <R> void |
Bot.wire(java.lang.String applicationId,
LedgerClient ledgerClient,
TransactionFilter transactionFilter,
java.util.function.Function<LedgerViewFlowable.LedgerView<R>,io.reactivex.Flowable<CommandsAndPendingSet>> bot,
java.util.function.Function<CreatedContract,R> transform)
|
static void |
Bot.wireSimple(java.lang.String appId,
LedgerClient ledgerClient,
TransactionFilter transactionFilter,
java.util.function.Function<LedgerViewFlowable.LedgerView<CreatedContract>,io.reactivex.Flowable<CommandsAndPendingSet>> bot)
|