com.daml.ledger.rxjava.components

Class Bot

java.lang.Object

com.daml.ledger.rxjava.components.Bot

public class Bot
extends java.lang.Object

A Bot is an automation that reacts to changes in the ledger by submitting zero or more commands. This class contains helpers to create bots. The main helper is wire(String, LedgerClient, TransactionFilter, Function, Function).

Constructor Summary

Constructors

Constructor and Description
Bot()

Method Summary

Modifier and Type	Method and Description
static <R> void	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	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	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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Bot

public Bot()

Method Detail

wire

public static <R> void 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.

Type Parameters:

R - The type of the result of transform.

Parameters:

applicationId - The application identifier that will be sent to the Ledger

ledgerClient - The LedgerClient instance which will be wired to the bot.

transactionFilter - A server-side filter of incoming transactions

bot - 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.

wire

public static <R> void 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.

Type Parameters:

R - The type of the result of transform.

Parameters:

applicationId - The application identifier that will be sent to the Ledger

ledgerClient - The LedgerClient instance which will be wired to the bot.

transactionFilter - A server-side filter of incoming transactions

bot - 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 flows

wireSimple

public static void 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.

Parameters:

appId - The application identifier that will be sent to the Ledger

ledgerClient - The LedgerClient instance which will be wired to the bot.

transactionFilter - A server-side filter of incoming transactions

bot - The business logic of the bot.