public class Bot
extends java.lang.Object
wire(String, LedgerClient, TransactionFilter, Function, Function)
.Constructor and Description |
---|
Bot() |
Modifier and Type | Method and Description |
---|---|
static <R> io.reactivex.disposables.Disposable |
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 |
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 |
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 . |
public static <R> io.reactivex.disposables.Disposable 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)
LedgerClient
instance.R
- The type of the result of transform.applicationId
- The application identifier that will be sent to the LedgerledgerClient
- The LedgerClient
instance which will be wired to the
bot.transactionFilter
- A server-side filter of incoming transactionsbot
- The business logic of the bot.transform
- A function from the arguments of a Contract on the Ledger to
a more refined type R. This can be used by the developer to, for
instance, discard the fields of a Contract that are not needed
and save space.public static <R> io.reactivex.disposables.Disposable 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)
LedgerClient
instance.R
- The type of the result of transform.applicationId
- The application identifier that will be sent to the LedgerledgerClient
- The LedgerClient
instance which will be wired to the
bot.transactionFilter
- A server-side filter of incoming transactionsbot
- The business logic of the bot.transform
- A function from the arguments of a Contract on the Ledger to
a more refined type R. This can be used by the developer to, for
instance, discard the fields of a Contract that are not needed
and save space.scheduler
- The scheduler used to run the flowspublic static io.reactivex.disposables.Disposable wireSimple(java.lang.String appId, LedgerClient ledgerClient, TransactionFilter transactionFilter, java.util.function.Function<LedgerViewFlowable.LedgerView<CreatedContract>,io.reactivex.Flowable<CommandsAndPendingSet>> bot)
LedgerClient
instance, storing CreatedContract
instances in the LedgerViewFlowable.LedgerView
.appId
- The application identifier that will be sent to the LedgerledgerClient
- The LedgerClient
instance which will be wired to the
bot.transactionFilter
- A server-side filter of incoming transactionsbot
- The business logic of the bot.