Package com.daml.ledger.rxjava

Interface StateClient

All Known Implementing Classes:
StateClientImpl
public interface StateClient
An RxJava version of StateServiceGrpc

  • Method Details

    • getActiveContracts

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

    • getActiveContracts

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

    • getActiveContracts

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

    • getActiveContracts

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

    • getActiveContracts

      <Ct> io.reactivex.Flowable<ActiveContracts<Ct>> getActiveContracts(ContractFilter<Ct> contractFilter, Set<String> parties, boolean verbose, Long activeAtOffset)
      Get active Contracts
      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

      <Ct> io.reactivex.Flowable<ActiveContracts<Ct>> getActiveContracts(ContractFilter<Ct> contractFilter, Set<String> parties, boolean verbose, Long activeAtOffset, String accessToken)
      Get active Contracts
      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

      io.reactivex.Single<Long> getLedgerEnd()

    • getLedgerEnd

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