Package com.daml.ledger.rxjava.grpc

Class TransactionClientImpl

    • 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

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <Ct> io.reactivex.Flowable<Ct> getContracts​(ContractUtil<Ct> contractUtil, com.daml.ledger.javaapi.data.LedgerOffset begin, java.util.Set<java.lang.String> parties, boolean verbose)
      Get contracts
      <Ct> io.reactivex.Flowable<Ct> getContracts​(ContractUtil<Ct> contractUtil, com.daml.ledger.javaapi.data.LedgerOffset begin, java.util.Set<java.lang.String> parties, boolean verbose, java.lang.String accessToken)
      Get contracts
      io.reactivex.Single<com.daml.ledger.javaapi.data.Transaction> getFlatTransactionByEventId​(java.lang.String eventId, java.util.Set<java.lang.String> requestingParties)  
      io.reactivex.Single<com.daml.ledger.javaapi.data.Transaction> getFlatTransactionByEventId​(java.lang.String eventId, java.util.Set<java.lang.String> requestingParties, java.lang.String accessToken)  
      io.reactivex.Single<com.daml.ledger.javaapi.data.Transaction> getFlatTransactionById​(java.lang.String transactionId, java.util.Set<java.lang.String> requestingParties)  
      io.reactivex.Single<com.daml.ledger.javaapi.data.Transaction> getFlatTransactionById​(java.lang.String transactionId, java.util.Set<java.lang.String> requestingParties, java.lang.String accessToken)  
      io.reactivex.Single<com.daml.ledger.javaapi.data.LedgerOffset> getLedgerEnd()  
      io.reactivex.Single<com.daml.ledger.javaapi.data.LedgerOffset> getLedgerEnd​(java.lang.String accessToken)  
      io.reactivex.Single<com.daml.ledger.javaapi.data.TransactionTree> getTransactionByEventId​(java.lang.String eventId, java.util.Set<java.lang.String> requestingParties)  
      io.reactivex.Single<com.daml.ledger.javaapi.data.TransactionTree> getTransactionByEventId​(java.lang.String eventId, java.util.Set<java.lang.String> requestingParties, java.lang.String accessToken)  
      io.reactivex.Single<com.daml.ledger.javaapi.data.TransactionTree> getTransactionById​(java.lang.String transactionId, java.util.Set<java.lang.String> requestingParties)  
      io.reactivex.Single<com.daml.ledger.javaapi.data.TransactionTree> getTransactionById​(java.lang.String transactionId, java.util.Set<java.lang.String> requestingParties, java.lang.String accessToken)  
      io.reactivex.Flowable<com.daml.ledger.javaapi.data.Transaction> getTransactions​(com.daml.ledger.javaapi.data.LedgerOffset begin, com.daml.ledger.javaapi.data.LedgerOffset end, com.daml.ledger.javaapi.data.TransactionFilter filter, boolean verbose)  
      io.reactivex.Flowable<com.daml.ledger.javaapi.data.Transaction> getTransactions​(com.daml.ledger.javaapi.data.LedgerOffset begin, com.daml.ledger.javaapi.data.LedgerOffset end, com.daml.ledger.javaapi.data.TransactionFilter filter, boolean verbose, java.lang.String accessToken)  
      io.reactivex.Flowable<com.daml.ledger.javaapi.data.Transaction> getTransactions​(com.daml.ledger.javaapi.data.LedgerOffset begin, com.daml.ledger.javaapi.data.TransactionFilter filter, boolean verbose)  
      io.reactivex.Flowable<com.daml.ledger.javaapi.data.Transaction> getTransactions​(com.daml.ledger.javaapi.data.LedgerOffset begin, com.daml.ledger.javaapi.data.TransactionFilter filter, boolean verbose, java.lang.String accessToken)  
      io.reactivex.Flowable<com.daml.ledger.javaapi.data.TransactionTree> getTransactionsTrees​(com.daml.ledger.javaapi.data.LedgerOffset begin, com.daml.ledger.javaapi.data.LedgerOffset end, com.daml.ledger.javaapi.data.TransactionFilter filter, boolean verbose)  
      io.reactivex.Flowable<com.daml.ledger.javaapi.data.TransactionTree> getTransactionsTrees​(com.daml.ledger.javaapi.data.LedgerOffset begin, com.daml.ledger.javaapi.data.LedgerOffset end, com.daml.ledger.javaapi.data.TransactionFilter filter, boolean verbose, java.lang.String accessToken)  
      io.reactivex.Flowable<com.daml.ledger.javaapi.data.TransactionTree> getTransactionsTrees​(com.daml.ledger.javaapi.data.LedgerOffset begin, com.daml.ledger.javaapi.data.TransactionFilter filter, boolean verbose)  
      io.reactivex.Flowable<com.daml.ledger.javaapi.data.TransactionTree> getTransactionsTrees​(com.daml.ledger.javaapi.data.LedgerOffset begin, com.daml.ledger.javaapi.data.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<com.daml.ledger.javaapi.data.Transaction> getTransactions​(com.daml.ledger.javaapi.data.LedgerOffset begin,
                                                                                       com.daml.ledger.javaapi.data.LedgerOffset end,
                                                                                       com.daml.ledger.javaapi.data.TransactionFilter filter,
                                                                                       boolean verbose)
        Specified by:
        getTransactions in interface TransactionsClient

      • getTransactions

        public io.reactivex.Flowable<com.daml.ledger.javaapi.data.Transaction> getTransactions​(com.daml.ledger.javaapi.data.LedgerOffset begin,
                                                                                       com.daml.ledger.javaapi.data.LedgerOffset end,
                                                                                       com.daml.ledger.javaapi.data.TransactionFilter filter,
                                                                                       boolean verbose,
                                                                                       java.lang.String accessToken)
        Specified by:
        getTransactions in interface TransactionsClient

      • getContracts

        public <Ct> io.reactivex.Flowable<Ct> getContracts​(ContractUtil<Ct> contractUtil,
                                                   com.daml.ledger.javaapi.data.LedgerOffset begin,
                                                   java.util.Set<java.lang.String> parties,
                                                   boolean verbose)
        Description copied from interface: TransactionsClient
        Get contracts
        Specified by:
        getContracts in interface TransactionsClient
        Parameters:
        contractUtil - Utilities for specified type of contract. It can be instantiated with ContractTypeCompanion
        begin - begin offset.
        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 contract type Ct

      • getContracts

        public <Ct> io.reactivex.Flowable<Ct> getContracts​(ContractUtil<Ct> contractUtil,
                                                   com.daml.ledger.javaapi.data.LedgerOffset begin,
                                                   java.util.Set<java.lang.String> parties,
                                                   boolean verbose,
                                                   java.lang.String accessToken)
        Description copied from interface: TransactionsClient
        Get contracts
        Specified by:
        getContracts in interface TransactionsClient
        Parameters:
        contractUtil - Utilities for specified type of contract. It can be instantiated with ContractTypeCompanion
        begin - begin offset.
        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:
        Flowable of contract type Ct

      • getTransactions

        public io.reactivex.Flowable<com.daml.ledger.javaapi.data.Transaction> getTransactions​(com.daml.ledger.javaapi.data.LedgerOffset begin,
                                                                                       com.daml.ledger.javaapi.data.TransactionFilter filter,
                                                                                       boolean verbose)
        Specified by:
        getTransactions in interface TransactionsClient

      • getTransactions

        public io.reactivex.Flowable<com.daml.ledger.javaapi.data.Transaction> getTransactions​(com.daml.ledger.javaapi.data.LedgerOffset begin,
                                                                                       com.daml.ledger.javaapi.data.TransactionFilter filter,
                                                                                       boolean verbose,
                                                                                       java.lang.String accessToken)
        Specified by:
        getTransactions in interface TransactionsClient

      • getTransactionsTrees

        public io.reactivex.Flowable<com.daml.ledger.javaapi.data.TransactionTree> getTransactionsTrees​(com.daml.ledger.javaapi.data.LedgerOffset begin,
                                                                                                com.daml.ledger.javaapi.data.TransactionFilter filter,
                                                                                                boolean verbose)
        Specified by:
        getTransactionsTrees in interface TransactionsClient

      • getTransactionsTrees

        public io.reactivex.Flowable<com.daml.ledger.javaapi.data.TransactionTree> getTransactionsTrees​(com.daml.ledger.javaapi.data.LedgerOffset begin,
                                                                                                com.daml.ledger.javaapi.data.TransactionFilter filter,
                                                                                                boolean verbose,
                                                                                                java.lang.String accessToken)
        Specified by:
        getTransactionsTrees in interface TransactionsClient

      • getTransactionsTrees

        public io.reactivex.Flowable<com.daml.ledger.javaapi.data.TransactionTree> getTransactionsTrees​(com.daml.ledger.javaapi.data.LedgerOffset begin,
                                                                                                com.daml.ledger.javaapi.data.LedgerOffset end,
                                                                                                com.daml.ledger.javaapi.data.TransactionFilter filter,
                                                                                                boolean verbose)
        Specified by:
        getTransactionsTrees in interface TransactionsClient

      • getTransactionsTrees

        public io.reactivex.Flowable<com.daml.ledger.javaapi.data.TransactionTree> getTransactionsTrees​(com.daml.ledger.javaapi.data.LedgerOffset begin,
                                                                                                com.daml.ledger.javaapi.data.LedgerOffset end,
                                                                                                com.daml.ledger.javaapi.data.TransactionFilter filter,
                                                                                                boolean verbose,
                                                                                                java.lang.String accessToken)
        Specified by:
        getTransactionsTrees in interface TransactionsClient

      • getTransactionByEventId

        public io.reactivex.Single<com.daml.ledger.javaapi.data.TransactionTree> getTransactionByEventId​(java.lang.String eventId,
                                                                                                 java.util.Set<java.lang.String> requestingParties)
        Specified by:
        getTransactionByEventId in interface TransactionsClient

      • getTransactionByEventId

        public io.reactivex.Single<com.daml.ledger.javaapi.data.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<com.daml.ledger.javaapi.data.TransactionTree> getTransactionById​(java.lang.String transactionId,
                                                                                            java.util.Set<java.lang.String> requestingParties)
        Specified by:
        getTransactionById in interface TransactionsClient

      • getTransactionById

        public io.reactivex.Single<com.daml.ledger.javaapi.data.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<com.daml.ledger.javaapi.data.Transaction> getFlatTransactionByEventId​(java.lang.String eventId,
                                                                                                 java.util.Set<java.lang.String> requestingParties)
        Specified by:
        getFlatTransactionByEventId in interface TransactionsClient

      • getFlatTransactionByEventId

        public io.reactivex.Single<com.daml.ledger.javaapi.data.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<com.daml.ledger.javaapi.data.Transaction> getFlatTransactionById​(java.lang.String transactionId,
                                                                                            java.util.Set<java.lang.String> requestingParties)
        Specified by:
        getFlatTransactionById in interface TransactionsClient

      • getFlatTransactionById

        public io.reactivex.Single<com.daml.ledger.javaapi.data.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<com.daml.ledger.javaapi.data.LedgerOffset> getLedgerEnd()
        Specified by:
        getLedgerEnd in interface TransactionsClient

      • getLedgerEnd

        public io.reactivex.Single<com.daml.ledger.javaapi.data.LedgerOffset> getLedgerEnd​(java.lang.String accessToken)
        Specified by:
        getLedgerEnd in interface TransactionsClient