Package com.daml.ledger.rxjava.grpc

Class StateClientImpl

java.lang.Object

com.daml.ledger.rxjava.grpc.StateClientImpl

All Implemented Interfaces:

StateClient

public class StateClientImpl
extends Object
implements StateClient

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
io.reactivex.Flowable<GetActiveContractsResponse>	getActiveContracts(@NonNull EventFormat eventFormat, Long activeAtOffset)
io.reactivex.Flowable<GetActiveContractsResponse>	getActiveContracts(@NonNull EventFormat eventFormat, Long activeAtOffset, @NonNull String accessToken)
io.reactivex.Flowable<GetActiveContractsResponse>	getActiveContracts(@NonNull TransactionFilter filter, boolean verbose, Long activeAtOffset)
io.reactivex.Flowable<GetActiveContractsResponse>	getActiveContracts(@NonNull TransactionFilter filter, boolean verbose, Long activeAtOffset, @NonNull String accessToken)
<Ct> io.reactivex.Flowable<ActiveContracts<Ct>>	getActiveContracts(ContractFilter<Ct> contractFilter, Set<String> parties, boolean verbose, Long activeAtOffset)	Get active Contracts
<Ct> io.reactivex.Flowable<ActiveContracts<Ct>>	getActiveContracts(ContractFilter<Ct> contractFilter, Set<String> parties, boolean verbose, Long activeAtOffset, String accessToken)	Get active Contracts
io.reactivex.Single<Long>	getLedgerEnd()
io.reactivex.Single<Long>	getLedgerEnd(String accessToken)

Methods inherited from class java.lang.Object

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

Constructor Details

StateClientImpl

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

Method Details

getActiveContracts

public io.reactivex.Flowable<GetActiveContractsResponse> getActiveContracts(@NonNull TransactionFilter filter,
 boolean verbose,
 Long activeAtOffset)

Specified by:

getActiveContracts in interface StateClient

getActiveContracts

public io.reactivex.Flowable<GetActiveContractsResponse> getActiveContracts(@NonNull TransactionFilter filter,
 boolean verbose,
 Long activeAtOffset,
 @NonNull String accessToken)

Specified by:

getActiveContracts in interface StateClient

getActiveContracts

public io.reactivex.Flowable<GetActiveContractsResponse> getActiveContracts(@NonNull EventFormat eventFormat,
 Long activeAtOffset)

Specified by:

getActiveContracts in interface StateClient

getActiveContracts

public io.reactivex.Flowable<GetActiveContractsResponse> getActiveContracts(@NonNull EventFormat eventFormat,
 Long activeAtOffset,
 @NonNull String accessToken)

Specified by:

getActiveContracts in interface StateClient

getActiveContracts

public <Ct>
io.reactivex.Flowable<ActiveContracts<Ct>> getActiveContracts(ContractFilter<Ct> contractFilter,
 Set<String> parties,
 boolean verbose,
 Long activeAtOffset)

Description copied from interface: StateClient

Get active Contracts

Specified by:

getActiveContracts in interface StateClient

Parameters:

contractFilter - Utilities for specified type of contract. It can be instantiated with ContractTypeCompanion

parties - Set of parties to be included in the transaction filter.

verbose - If enabled, values served over the API will contain more information than strictly necessary to interpret the data.

activeAtOffset - The offset at which the snapshot of the active contracts will be computed.

Returns:

Flowable of active contracts of type Ct

getActiveContracts

public <Ct>
io.reactivex.Flowable<ActiveContracts<Ct>> getActiveContracts(ContractFilter<Ct> contractFilter,
 Set<String> parties,
 boolean verbose,
 Long activeAtOffset,
 String accessToken)

Description copied from interface: StateClient

Get active Contracts

Specified by:

getActiveContracts in interface StateClient

Parameters:

contractFilter - Utilities for specified type of contract. It can be instantiated with ContractTypeCompanion

parties - Set of parties to be included in the transaction filter.

verbose - If enabled, values served over the API will contain more information than strictly necessary to interpret the data.

activeAtOffset - The offset at which the snapshot of the active contracts will be computed.

accessToken - Access token for authentication.

Returns:

Active contracts of type Ct

getLedgerEnd

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

Specified by:

getLedgerEnd in interface StateClient

getLedgerEnd

public io.reactivex.Single<Long> getLedgerEnd(String accessToken)

Specified by:

getLedgerEnd in interface StateClient