Package com.daml.ledger.rxjava.grpc

Class CommandCompletionClientImpl

java.lang.Object

com.daml.ledger.rxjava.grpc.CommandCompletionClientImpl

All Implemented Interfaces:

CommandCompletionClient

public class CommandCompletionClientImpl
extends Object
implements CommandCompletionClient

Constructor Summary

Constructors

Constructor	Description
CommandCompletionClientImpl(io.grpc.Channel channel, com.daml.grpc.adapter.ExecutionSequencerFactory sequencerFactory, Optional<String> accessToken)

Method Summary

Modifier and Type	Method	Description
io.reactivex.Flowable<CompletionStreamResponse>	completionStream(String userId, Long offset, List<String> parties)
io.reactivex.Flowable<CompletionStreamResponse>	completionStream(String userId, Long offset, List<String> parties, String accessToken)
io.reactivex.Flowable<CompletionStreamResponse>	completionStream(String userId, List<String> parties)
io.reactivex.Flowable<CompletionStreamResponse>	completionStream(String userId, List<String> parties, String accessToken)

Methods inherited from class java.lang.Object

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

Constructor Details

CommandCompletionClientImpl

public CommandCompletionClientImpl(io.grpc.Channel channel,
 com.daml.grpc.adapter.ExecutionSequencerFactory sequencerFactory,
 Optional<String> accessToken)

Method Details

completionStream

public io.reactivex.Flowable<CompletionStreamResponse> completionStream(String userId,
 Long offset,
 List<String> parties)

Specified by:

completionStream in interface CommandCompletionClient

completionStream

public io.reactivex.Flowable<CompletionStreamResponse> completionStream(String userId,
 Long offset,
 List<String> parties,
 String accessToken)

Specified by:

completionStream in interface CommandCompletionClient

completionStream

public io.reactivex.Flowable<CompletionStreamResponse> completionStream(String userId,
 List<String> parties)

Specified by:

completionStream in interface CommandCompletionClient

completionStream

public io.reactivex.Flowable<CompletionStreamResponse> completionStream(String userId,
 List<String> parties,
 String accessToken)

Specified by:

completionStream in interface CommandCompletionClient