Package com.daml.ledger.rxjava.grpc

Class UpdateClientImpl

java.lang.Object

com.daml.ledger.rxjava.grpc.UpdateClientImpl

All Implemented Interfaces:

UpdateClient

public final class UpdateClientImpl
extends Object
implements UpdateClient

Constructor Summary

Constructors

Constructor	Description
UpdateClientImpl(io.grpc.Channel channel, com.daml.grpc.adapter.ExecutionSequencerFactory sequencerFactory, Optional<String> accessToken)

Method Summary

Modifier and Type	Method	Description
io.reactivex.Single<Transaction>	getTransactionById(String transactionId, Set<String> requestingParties)
io.reactivex.Single<Transaction>	getTransactionById(String transactionId, Set<String> requestingParties, String accessToken)
io.reactivex.Single<Transaction>	getTransactionByOffset(Long offset, Set<String> requestingParties)
io.reactivex.Single<Transaction>	getTransactionByOffset(Long offset, Set<String> requestingParties, String accessToken)
io.reactivex.Flowable<Transaction>	getTransactions(ContractFilter<?> contractFilter, Long begin, Optional<Long> end, Set<String> parties, boolean verbose)
io.reactivex.Flowable<Transaction>	getTransactions(Long begin, Optional<Long> end, TransactionFilter filter, boolean verbose)
io.reactivex.Flowable<Transaction>	getTransactions(Long begin, Optional<Long> end, TransactionFilter filter, boolean verbose, String accessToken)
io.reactivex.Flowable<Transaction>	getTransactions(Long begin, Optional<Long> end, TransactionFormat transactionFormat)
io.reactivex.Flowable<Transaction>	getTransactions(Long begin, Optional<Long> end, TransactionFormat transactionFormat, String accessToken)
io.reactivex.Flowable<TransactionTree>	getTransactionsTrees(Long begin, Optional<Long> end, TransactionFilter filter, boolean verbose)
io.reactivex.Flowable<TransactionTree>	getTransactionsTrees(Long begin, Optional<Long> end, TransactionFilter filter, boolean verbose, String accessToken)
io.reactivex.Single<TransactionTree>	getTransactionTreeById(String transactionId, Set<String> requestingParties)
io.reactivex.Single<TransactionTree>	getTransactionTreeById(String transactionId, Set<String> requestingParties, String accessToken)
io.reactivex.Single<TransactionTree>	getTransactionTreeByOffset(Long offset, Set<String> requestingParties)
io.reactivex.Single<TransactionTree>	getTransactionTreeByOffset(Long offset, Set<String> requestingParties, String accessToken)

Methods inherited from class java.lang.Object

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

Constructor Details

UpdateClientImpl

public UpdateClientImpl(io.grpc.Channel channel,
 com.daml.grpc.adapter.ExecutionSequencerFactory sequencerFactory,
 Optional<String> accessToken)

Method Details

getTransactions

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

Specified by:

getTransactions in interface UpdateClient

getTransactions

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

Specified by:

getTransactions in interface UpdateClient

getTransactions

public io.reactivex.Flowable<Transaction> getTransactions(ContractFilter<?> contractFilter,
 Long begin,
 Optional<Long> end,
 Set<String> parties,
 boolean verbose)

Specified by:

getTransactions in interface UpdateClient

getTransactions

public io.reactivex.Flowable<Transaction> getTransactions(Long begin,
 Optional<Long> end,
 TransactionFormat transactionFormat)

Specified by:

getTransactions in interface UpdateClient

getTransactions

public io.reactivex.Flowable<Transaction> getTransactions(Long begin,
 Optional<Long> end,
 TransactionFormat transactionFormat,
 String accessToken)

Specified by:

getTransactions in interface UpdateClient

getTransactionsTrees

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

Specified by:

getTransactionsTrees in interface UpdateClient

getTransactionsTrees

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

Specified by:

getTransactionsTrees in interface UpdateClient

getTransactionTreeByOffset

public io.reactivex.Single<TransactionTree> getTransactionTreeByOffset(Long offset,
 Set<String> requestingParties)

Specified by:

getTransactionTreeByOffset in interface UpdateClient

getTransactionTreeByOffset

public io.reactivex.Single<TransactionTree> getTransactionTreeByOffset(Long offset,
 Set<String> requestingParties,
 String accessToken)

Specified by:

getTransactionTreeByOffset in interface UpdateClient

getTransactionTreeById

public io.reactivex.Single<TransactionTree> getTransactionTreeById(String transactionId,
 Set<String> requestingParties)

Specified by:

getTransactionTreeById in interface UpdateClient

getTransactionTreeById

public io.reactivex.Single<TransactionTree> getTransactionTreeById(String transactionId,
 Set<String> requestingParties,
 String accessToken)

Specified by:

getTransactionTreeById in interface UpdateClient

getTransactionByOffset

public io.reactivex.Single<Transaction> getTransactionByOffset(Long offset,
 Set<String> requestingParties)

Specified by:

getTransactionByOffset in interface UpdateClient

getTransactionByOffset

public io.reactivex.Single<Transaction> getTransactionByOffset(Long offset,
 Set<String> requestingParties,
 String accessToken)

Specified by:

getTransactionByOffset in interface UpdateClient

getTransactionById

public io.reactivex.Single<Transaction> getTransactionById(String transactionId,
 Set<String> requestingParties)

Specified by:

getTransactionById in interface UpdateClient

getTransactionById

public io.reactivex.Single<Transaction> getTransactionById(String transactionId,
 Set<String> requestingParties,
 String accessToken)

Specified by:

getTransactionById in interface UpdateClient