Package com.daml.ledger.rxjava.grpc

Class TransactionClientImpl

java.lang.Object

com.daml.ledger.rxjava.grpc.TransactionClientImpl

All Implemented Interfaces:

TransactionsClient

public final class TransactionClientImpl
extends java.lang.Object
implements TransactionsClient

Constructor Summary

Constructors

Constructor	Description
TransactionClientImpl(java.lang.String ledgerId, io.grpc.Channel channel, com.daml.grpc.adapter.ExecutionSequencerFactory sequencerFactory, java.util.Optional<java.lang.String> accessToken)

Method Summary

Modifier and Type	Method	Description
io.reactivex.Single<Transaction>	getFlatTransactionByEventId(java.lang.String eventId, java.util.Set<java.lang.String> requestingParties)
io.reactivex.Single<Transaction>	getFlatTransactionByEventId(java.lang.String eventId, java.util.Set<java.lang.String> requestingParties, java.lang.String accessToken)
io.reactivex.Single<Transaction>	getFlatTransactionById(java.lang.String transactionId, java.util.Set<java.lang.String> requestingParties)
io.reactivex.Single<Transaction>	getFlatTransactionById(java.lang.String transactionId, java.util.Set<java.lang.String> requestingParties, java.lang.String accessToken)
io.reactivex.Single<LedgerOffset>	getLedgerEnd()
io.reactivex.Single<LedgerOffset>	getLedgerEnd(java.lang.String accessToken)
io.reactivex.Single<TransactionTree>	getTransactionByEventId(java.lang.String eventId, java.util.Set<java.lang.String> requestingParties)
io.reactivex.Single<TransactionTree>	getTransactionByEventId(java.lang.String eventId, java.util.Set<java.lang.String> requestingParties, java.lang.String accessToken)
io.reactivex.Single<TransactionTree>	getTransactionById(java.lang.String transactionId, java.util.Set<java.lang.String> requestingParties)
io.reactivex.Single<TransactionTree>	getTransactionById(java.lang.String transactionId, java.util.Set<java.lang.String> requestingParties, java.lang.String accessToken)
io.reactivex.Flowable<Transaction>	getTransactions(LedgerOffset begin, LedgerOffset end, TransactionFilter filter, boolean verbose)
io.reactivex.Flowable<Transaction>	getTransactions(LedgerOffset begin, LedgerOffset end, TransactionFilter filter, boolean verbose, java.lang.String accessToken)
io.reactivex.Flowable<Transaction>	getTransactions(LedgerOffset begin, TransactionFilter filter, boolean verbose)
io.reactivex.Flowable<Transaction>	getTransactions(LedgerOffset begin, TransactionFilter filter, boolean verbose, java.lang.String accessToken)
io.reactivex.Flowable<TransactionTree>	getTransactionsTrees(LedgerOffset begin, LedgerOffset end, TransactionFilter filter, boolean verbose)
io.reactivex.Flowable<TransactionTree>	getTransactionsTrees(LedgerOffset begin, LedgerOffset end, TransactionFilter filter, boolean verbose, java.lang.String accessToken)
io.reactivex.Flowable<TransactionTree>	getTransactionsTrees(LedgerOffset begin, TransactionFilter filter, boolean verbose)
io.reactivex.Flowable<TransactionTree>	getTransactionsTrees(LedgerOffset begin, TransactionFilter filter, boolean verbose, java.lang.String accessToken)

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactionClientImpl

public TransactionClientImpl(java.lang.String ledgerId,
                             io.grpc.Channel channel,
                             com.daml.grpc.adapter.ExecutionSequencerFactory sequencerFactory,
                             java.util.Optional<java.lang.String> accessToken)

Method Detail

getTransactions

public io.reactivex.Flowable<Transaction> getTransactions(LedgerOffset begin,
                                                          LedgerOffset end,
                                                          TransactionFilter filter,
                                                          boolean verbose)

Specified by:

getTransactions in interface TransactionsClient

getTransactions

public io.reactivex.Flowable<Transaction> getTransactions(LedgerOffset begin,
                                                          LedgerOffset end,
                                                          TransactionFilter filter,
                                                          boolean verbose,
                                                          java.lang.String accessToken)

Specified by:

getTransactions in interface TransactionsClient

getTransactions

public io.reactivex.Flowable<Transaction> getTransactions(LedgerOffset begin,
                                                          TransactionFilter filter,
                                                          boolean verbose)

Specified by:

getTransactions in interface TransactionsClient

getTransactions

public io.reactivex.Flowable<Transaction> getTransactions(LedgerOffset begin,
                                                          TransactionFilter filter,
                                                          boolean verbose,
                                                          java.lang.String accessToken)

Specified by:

getTransactions in interface TransactionsClient

getTransactionsTrees

public io.reactivex.Flowable<TransactionTree> getTransactionsTrees(LedgerOffset begin,
                                                                   TransactionFilter filter,
                                                                   boolean verbose)

Specified by:

getTransactionsTrees in interface TransactionsClient

getTransactionsTrees

public io.reactivex.Flowable<TransactionTree> getTransactionsTrees(LedgerOffset begin,
                                                                   TransactionFilter filter,
                                                                   boolean verbose,
                                                                   java.lang.String accessToken)

Specified by:

getTransactionsTrees in interface TransactionsClient

getTransactionsTrees

public io.reactivex.Flowable<TransactionTree> getTransactionsTrees(LedgerOffset begin,
                                                                   LedgerOffset end,
                                                                   TransactionFilter filter,
                                                                   boolean verbose)

Specified by:

getTransactionsTrees in interface TransactionsClient

getTransactionsTrees

public io.reactivex.Flowable<TransactionTree> getTransactionsTrees(LedgerOffset begin,
                                                                   LedgerOffset end,
                                                                   TransactionFilter filter,
                                                                   boolean verbose,
                                                                   java.lang.String accessToken)

Specified by:

getTransactionsTrees in interface TransactionsClient

getTransactionByEventId

public io.reactivex.Single<TransactionTree> getTransactionByEventId(java.lang.String eventId,
                                                                    java.util.Set<java.lang.String> requestingParties)

Specified by:

getTransactionByEventId in interface TransactionsClient

getTransactionByEventId

public io.reactivex.Single<TransactionTree> getTransactionByEventId(java.lang.String eventId,
                                                                    java.util.Set<java.lang.String> requestingParties,
                                                                    java.lang.String accessToken)

Specified by:

getTransactionByEventId in interface TransactionsClient

getTransactionById

public io.reactivex.Single<TransactionTree> getTransactionById(java.lang.String transactionId,
                                                               java.util.Set<java.lang.String> requestingParties)

Specified by:

getTransactionById in interface TransactionsClient

getTransactionById

public io.reactivex.Single<TransactionTree> getTransactionById(java.lang.String transactionId,
                                                               java.util.Set<java.lang.String> requestingParties,
                                                               java.lang.String accessToken)

Specified by:

getTransactionById in interface TransactionsClient

getFlatTransactionByEventId

public io.reactivex.Single<Transaction> getFlatTransactionByEventId(java.lang.String eventId,
                                                                    java.util.Set<java.lang.String> requestingParties)

Specified by:

getFlatTransactionByEventId in interface TransactionsClient

getFlatTransactionByEventId

public io.reactivex.Single<Transaction> getFlatTransactionByEventId(java.lang.String eventId,
                                                                    java.util.Set<java.lang.String> requestingParties,
                                                                    java.lang.String accessToken)

Specified by:

getFlatTransactionByEventId in interface TransactionsClient

getFlatTransactionById

public io.reactivex.Single<Transaction> getFlatTransactionById(java.lang.String transactionId,
                                                               java.util.Set<java.lang.String> requestingParties)

Specified by:

getFlatTransactionById in interface TransactionsClient

getFlatTransactionById

public io.reactivex.Single<Transaction> getFlatTransactionById(java.lang.String transactionId,
                                                               java.util.Set<java.lang.String> requestingParties,
                                                               java.lang.String accessToken)

Specified by:

getFlatTransactionById in interface TransactionsClient

getLedgerEnd

public io.reactivex.Single<LedgerOffset> getLedgerEnd()

Specified by:

getLedgerEnd in interface TransactionsClient

getLedgerEnd

public io.reactivex.Single<LedgerOffset> getLedgerEnd(java.lang.String accessToken)

Specified by:

getLedgerEnd in interface TransactionsClient