com.daml.ledger.rxjava

Interface CommandCompletionClient

All Known Implementing Classes:

CommandCompletionClientImpl

public interface CommandCompletionClient

An RxJava version of CommandCompletionServiceGrpc

Method Summary

Modifier and Type	Method and Description
io.reactivex.Single<CompletionEndResponse>	completionEnd()
io.reactivex.Single<CompletionEndResponse>	completionEnd(java.lang.String accessToken)
io.reactivex.Flowable<CompletionStreamResponse>	completionStream(java.lang.String applicationId, LedgerOffset offset, java.util.Set<java.lang.String> parties)
io.reactivex.Flowable<CompletionStreamResponse>	completionStream(java.lang.String applicationId, LedgerOffset offset, java.util.Set<java.lang.String> parties, java.lang.String accessToken)
io.reactivex.Flowable<CompletionStreamResponse>	completionStream(java.lang.String applicationId, java.util.Set<java.lang.String> parties)
io.reactivex.Flowable<CompletionStreamResponse>	completionStream(java.lang.String applicationId, java.util.Set<java.lang.String> parties, java.lang.String accessToken)

Method Detail

completionStream

io.reactivex.Flowable<CompletionStreamResponse> completionStream(java.lang.String applicationId,
                                                                 LedgerOffset offset,
                                                                 java.util.Set<java.lang.String> parties)

completionStream

io.reactivex.Flowable<CompletionStreamResponse> completionStream(java.lang.String applicationId,
                                                                 LedgerOffset offset,
                                                                 java.util.Set<java.lang.String> parties,
                                                                 java.lang.String accessToken)

completionStream

io.reactivex.Flowable<CompletionStreamResponse> completionStream(java.lang.String applicationId,
                                                                 java.util.Set<java.lang.String> parties)

completionStream

io.reactivex.Flowable<CompletionStreamResponse> completionStream(java.lang.String applicationId,
                                                                 java.util.Set<java.lang.String> parties,
                                                                 java.lang.String accessToken)

completionEnd

io.reactivex.Single<CompletionEndResponse> completionEnd()

completionEnd

io.reactivex.Single<CompletionEndResponse> completionEnd(java.lang.String accessToken)