| 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> 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. | 
| Modifier and Type | Method and Description | 
|---|---|
static java.util.function.Function<CreatedContract,Template> | 
TemplateUtils.contractTransformer(java.lang.Class<? extends Template>... allowedTemplates)
Creates a transform function which is aware of the template types. 
 |