com.daml.ledger.rxjava.grpc

Class CommandSubmissionClientImpl

java.lang.Object

com.daml.ledger.rxjava.grpc.CommandSubmissionClientImpl

All Implemented Interfaces:

CommandSubmissionClient

public class CommandSubmissionClientImpl
extends java.lang.Object
implements CommandSubmissionClient

Constructor Summary

Constructors

Constructor and Description
CommandSubmissionClientImpl(@NonNull java.lang.String ledgerId, @NonNull io.grpc.Channel channel, java.util.Optional<java.lang.String> accessToken, java.util.Optional<io.grpc.Deadline> deadline)

Method Summary

Modifier and Type	Method and 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.util.List<java.lang.String> actAs, @NonNull java.util.List<java.lang.String> readAs, @NonNull java.util.List<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<java.lang.String> actAs, @NonNull java.util.List<java.lang.String> readAs, @NonNull java.util.List<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<java.lang.String> actAs, @NonNull java.util.List<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<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<java.lang.String> actAs, @NonNull java.util.List<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<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<java.lang.String> actAs, @NonNull java.util.List<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<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.List<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<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<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<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.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<Command> commands, @NonNull 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,
                                   java.util.Optional<java.lang.String> accessToken,
                                   java.util.Optional<io.grpc.Deadline> deadline)

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<java.lang.String> actAs,
                                                             @NonNull java.util.List<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<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<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<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<java.lang.String> actAs,
                                                             @NonNull java.util.List<java.lang.String> readAs,
                                                             @NonNull java.util.List<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<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<java.lang.String> actAs,
                                                             @NonNull java.util.List<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<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<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<java.lang.String> actAs,
                                                             @NonNull java.util.List<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<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<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<java.lang.String> actAs,
                                                             @NonNull java.util.List<java.lang.String> readAs,
                                                             @NonNull java.util.List<Command> commands,
                                                             @NonNull java.lang.String accessToken)

Specified by:

submit in interface CommandSubmissionClient