Package | Description |
---|---|
com.daml.ledger.rxjava.components | |
com.daml.ledger.rxjava.components.helpers |
Modifier and Type | Method and Description |
---|---|
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)
Wires the Bot logic to an existing
LedgerClient instance. |
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,
io.reactivex.Scheduler scheduler)
Wires the Bot logic to an existing
LedgerClient instance. |
static void |
Bot.wireSimple(java.lang.String appId,
LedgerClient ledgerClient,
TransactionFilter transactionFilter,
java.util.function.Function<LedgerViewFlowable.LedgerView<CreatedContract>,io.reactivex.Flowable<CommandsAndPendingSet>> bot)
Wires the Bot logic to an existing
LedgerClient instance, storing CreatedContract
instances in the LedgerViewFlowable.LedgerView . |
Modifier and Type | Field and Description |
---|---|
static CommandsAndPendingSet |
CommandsAndPendingSet.empty |