Package com.daml.ledger.rxjava.grpc

Class CommandSubmissionClientImpl

    • Constructor Summary

      Constructors 
      Constructor Description
      CommandSubmissionClientImpl​(@NonNull java.lang.String ledgerId, @NonNull io.grpc.Channel channel, com.daml.grpc.adapter.ExecutionSequencerFactory sequencerFactory, java.util.Optional<java.lang.String> accessToken, java.util.Optional<java.time.Duration> timeout)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId, @NonNull java.lang.String applicationId, @NonNull java.lang.String commandId, @NonNull java.lang.String party, @NonNull java.util.List<@NonNull Command> commands)  
      io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId, @NonNull java.lang.String applicationId, @NonNull java.lang.String commandId, @NonNull java.lang.String party, @NonNull java.util.List<@NonNull Command> commands, @NonNull java.lang.String accessToken)  
      io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId, @NonNull java.lang.String applicationId, @NonNull java.lang.String commandId, @NonNull java.lang.String party, @NonNull java.util.Optional<java.time.Instant> minLedgerTimeAbs, @NonNull java.util.Optional<java.time.Duration> minLedgerTimeRel, @NonNull java.util.Optional<java.time.Duration> deduplicationTime, @NonNull java.util.List<@NonNull Command> commands)  
      io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId, @NonNull java.lang.String applicationId, @NonNull java.lang.String commandId, @NonNull java.lang.String party, @NonNull java.util.Optional<java.time.Instant> minLedgerTimeAbs, @NonNull java.util.Optional<java.time.Duration> minLedgerTimeRel, @NonNull java.util.Optional<java.time.Duration> deduplicationTime, @NonNull java.util.List<@NonNull Command> commands, @NonNull java.lang.String accessToken)  
      io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId, @NonNull java.lang.String applicationId, @NonNull java.lang.String commandId, @NonNull java.lang.String party, @NonNull java.util.Optional<java.time.Instant> minLedgerTimeAbs, @NonNull java.util.Optional<java.time.Duration> minLedgerTimeRel, @NonNull java.util.Optional<java.time.Duration> deduplicationTime, @NonNull java.util.List<@NonNull Command> commands, java.util.Optional<java.lang.String> accessToken)  
      io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId, @NonNull java.lang.String applicationId, @NonNull java.lang.String commandId, @NonNull java.util.List<@NonNull java.lang.String> actAs, @NonNull java.util.List<@NonNull java.lang.String> readAs, @NonNull java.util.List<@NonNull Command> commands)  
      io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId, @NonNull java.lang.String applicationId, @NonNull java.lang.String commandId, @NonNull java.util.List<@NonNull java.lang.String> actAs, @NonNull java.util.List<@NonNull java.lang.String> readAs, @NonNull java.util.List<@NonNull Command> commands, @NonNull java.lang.String accessToken)  
      io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId, @NonNull java.lang.String applicationId, @NonNull java.lang.String commandId, @NonNull java.util.List<@NonNull java.lang.String> actAs, @NonNull java.util.List<@NonNull java.lang.String> readAs, @NonNull java.util.Optional<java.time.Instant> minLedgerTimeAbs, @NonNull java.util.Optional<java.time.Duration> minLedgerTimeRel, @NonNull java.util.Optional<java.time.Duration> deduplicationTime, @NonNull java.util.List<@NonNull Command> commands)  
      io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId, @NonNull java.lang.String applicationId, @NonNull java.lang.String commandId, @NonNull java.util.List<@NonNull java.lang.String> actAs, @NonNull java.util.List<@NonNull java.lang.String> readAs, @NonNull java.util.Optional<java.time.Instant> minLedgerTimeAbs, @NonNull java.util.Optional<java.time.Duration> minLedgerTimeRel, @NonNull java.util.Optional<java.time.Duration> deduplicationTime, @NonNull java.util.List<@NonNull Command> commands, @NonNull java.lang.String accessToken)  
      io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId, @NonNull java.lang.String applicationId, @NonNull java.lang.String commandId, @NonNull java.util.List<@NonNull java.lang.String> actAs, @NonNull java.util.List<@NonNull java.lang.String> readAs, @NonNull java.util.Optional<java.time.Instant> minLedgerTimeAbs, @NonNull java.util.Optional<java.time.Duration> minLedgerTimeRel, @NonNull java.util.Optional<java.time.Duration> deduplicationTime, @NonNull java.util.List<@NonNull Command> commands, java.util.Optional<java.lang.String> accessToken)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • CommandSubmissionClientImpl

        public CommandSubmissionClientImpl​(@NonNull java.lang.String ledgerId,
                                   @NonNull io.grpc.Channel channel,
                                   com.daml.grpc.adapter.ExecutionSequencerFactory sequencerFactory,
                                   java.util.Optional<java.lang.String> accessToken,
                                   java.util.Optional<java.time.Duration> timeout)

    • Method Detail

      • submit

        public io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId,
                                                             @NonNull java.lang.String applicationId,
                                                             @NonNull java.lang.String commandId,
                                                             @NonNull java.util.List<@NonNull java.lang.String> actAs,
                                                             @NonNull java.util.List<@NonNull java.lang.String> readAs,
                                                             @NonNull java.util.Optional<java.time.Instant> minLedgerTimeAbs,
                                                             @NonNull java.util.Optional<java.time.Duration> minLedgerTimeRel,
                                                             @NonNull java.util.Optional<java.time.Duration> deduplicationTime,
                                                             @NonNull java.util.List<@NonNull Command> commands,
                                                             java.util.Optional<java.lang.String> accessToken)

      • submit

        public io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId,
                                                             @NonNull java.lang.String applicationId,
                                                             @NonNull java.lang.String commandId,
                                                             @NonNull java.lang.String party,
                                                             @NonNull java.util.Optional<java.time.Instant> minLedgerTimeAbs,
                                                             @NonNull java.util.Optional<java.time.Duration> minLedgerTimeRel,
                                                             @NonNull java.util.Optional<java.time.Duration> deduplicationTime,
                                                             @NonNull java.util.List<@NonNull Command> commands,
                                                             java.util.Optional<java.lang.String> accessToken)

      • submit

        public io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId,
                                                             @NonNull java.lang.String applicationId,
                                                             @NonNull java.lang.String commandId,
                                                             @NonNull java.lang.String party,
                                                             @NonNull java.util.List<@NonNull Command> commands)
        Specified by:
        submit in interface CommandSubmissionClient

      • submit

        public io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId,
                                                             @NonNull java.lang.String applicationId,
                                                             @NonNull java.lang.String commandId,
                                                             @NonNull java.util.List<@NonNull java.lang.String> actAs,
                                                             @NonNull java.util.List<@NonNull java.lang.String> readAs,
                                                             @NonNull java.util.List<@NonNull Command> commands)
        Specified by:
        submit in interface CommandSubmissionClient

      • submit

        public io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId,
                                                             @NonNull java.lang.String applicationId,
                                                             @NonNull java.lang.String commandId,
                                                             @NonNull java.lang.String party,
                                                             @NonNull java.util.Optional<java.time.Instant> minLedgerTimeAbs,
                                                             @NonNull java.util.Optional<java.time.Duration> minLedgerTimeRel,
                                                             @NonNull java.util.Optional<java.time.Duration> deduplicationTime,
                                                             @NonNull java.util.List<@NonNull Command> commands,
                                                             @NonNull java.lang.String accessToken)
        Specified by:
        submit in interface CommandSubmissionClient

      • submit

        public io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId,
                                                             @NonNull java.lang.String applicationId,
                                                             @NonNull java.lang.String commandId,
                                                             @NonNull java.util.List<@NonNull java.lang.String> actAs,
                                                             @NonNull java.util.List<@NonNull java.lang.String> readAs,
                                                             @NonNull java.util.Optional<java.time.Instant> minLedgerTimeAbs,
                                                             @NonNull java.util.Optional<java.time.Duration> minLedgerTimeRel,
                                                             @NonNull java.util.Optional<java.time.Duration> deduplicationTime,
                                                             @NonNull java.util.List<@NonNull Command> commands,
                                                             @NonNull java.lang.String accessToken)
        Specified by:
        submit in interface CommandSubmissionClient

      • submit

        public io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId,
                                                             @NonNull java.lang.String applicationId,
                                                             @NonNull java.lang.String commandId,
                                                             @NonNull java.lang.String party,
                                                             @NonNull java.util.Optional<java.time.Instant> minLedgerTimeAbs,
                                                             @NonNull java.util.Optional<java.time.Duration> minLedgerTimeRel,
                                                             @NonNull java.util.Optional<java.time.Duration> deduplicationTime,
                                                             @NonNull java.util.List<@NonNull Command> commands)
        Specified by:
        submit in interface CommandSubmissionClient

      • submit

        public io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId,
                                                             @NonNull java.lang.String applicationId,
                                                             @NonNull java.lang.String commandId,
                                                             @NonNull java.util.List<@NonNull java.lang.String> actAs,
                                                             @NonNull java.util.List<@NonNull java.lang.String> readAs,
                                                             @NonNull java.util.Optional<java.time.Instant> minLedgerTimeAbs,
                                                             @NonNull java.util.Optional<java.time.Duration> minLedgerTimeRel,
                                                             @NonNull java.util.Optional<java.time.Duration> deduplicationTime,
                                                             @NonNull java.util.List<@NonNull Command> commands)
        Specified by:
        submit in interface CommandSubmissionClient

      • submit

        public io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId,
                                                             @NonNull java.lang.String applicationId,
                                                             @NonNull java.lang.String commandId,
                                                             @NonNull java.lang.String party,
                                                             @NonNull java.util.List<@NonNull Command> commands,
                                                             @NonNull java.lang.String accessToken)
        Specified by:
        submit in interface CommandSubmissionClient

      • submit

        public io.reactivex.Single<com.google.protobuf.Empty> submit​(@NonNull java.lang.String workflowId,
                                                             @NonNull java.lang.String applicationId,
                                                             @NonNull java.lang.String commandId,
                                                             @NonNull java.util.List<@NonNull java.lang.String> actAs,
                                                             @NonNull java.util.List<@NonNull java.lang.String> readAs,
                                                             @NonNull java.util.List<@NonNull Command> commands,
                                                             @NonNull java.lang.String accessToken)
        Specified by:
        submit in interface CommandSubmissionClient