Package com.daml.ledger.rxjava.grpc

Class ActiveContractClientImpl

java.lang.Object

com.daml.ledger.rxjava.grpc.ActiveContractClientImpl

All Implemented Interfaces:

ActiveContractsClient

public class ActiveContractClientImpl
extends java.lang.Object
implements ActiveContractsClient

Constructor Summary

Constructors

Constructor	Description
ActiveContractClientImpl(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.Flowable<GetActiveContractsResponse>	getActiveContracts(@NonNull TransactionFilter filter, boolean verbose)
io.reactivex.Flowable<GetActiveContractsResponse>	getActiveContracts(@NonNull TransactionFilter filter, boolean verbose, @NonNull java.lang.String accessToken)
<Ct> io.reactivex.Flowable<ActiveContracts<Ct>>	getActiveContracts(ContractFilter<Ct> contractFilter, java.util.Set<java.lang.String> parties, boolean verbose)	Get active Contracts
<Ct> io.reactivex.Flowable<ActiveContracts<Ct>>	getActiveContracts(ContractFilter<Ct> contractFilter, java.util.Set<java.lang.String> parties, boolean verbose, java.lang.String accessToken)	Get active Contracts

Methods inherited from class java.lang.Object

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

Constructor Detail

ActiveContractClientImpl

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

Method Detail

getActiveContracts

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

Specified by:

getActiveContracts in interface ActiveContractsClient

getActiveContracts

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

Specified by:

getActiveContracts in interface ActiveContractsClient

getActiveContracts

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

Description copied from interface: ActiveContractsClient

Get active Contracts

Specified by:

getActiveContracts in interface ActiveContractsClient

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.

Returns:

Flowable of active contracts of type Ct

getActiveContracts

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

Description copied from interface: ActiveContractsClient

Get active Contracts

Specified by:

getActiveContracts in interface ActiveContractsClient

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.

accessToken - Access token for authentication.

Returns:

Active contracts of type Ct