Package | Description |
---|---|
com.daml.ledger.rxjava.components |
Modifier and Type | Class and Description |
---|---|
static class |
LedgerViewFlowable.LedgerTestView<R>
A ledger view for unit testing of bots.
|
Modifier and Type | Method and Description |
---|---|
static <R> LedgerViewFlowable.LedgerView<R> |
LedgerViewFlowable.LedgerView.create()
Creates a new empty view of the Ledger.
|
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) |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
static <R> io.reactivex.disposables.Disposable |
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> io.reactivex.disposables.Disposable |
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 io.reactivex.disposables.Disposable |
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 . |