com.daml.ledger.rxjava

Interface CommandCompletionClient

public interface CommandCompletionClient

An RxJava version of CommandCompletionServiceGrpc

Method Summary

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

Method Detail

completionStream

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

completionStream

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

completionStream

io.reactivex.Flowable<com.daml.ledger.javaapi.data.CompletionStreamResponse> completionStream(java.lang.String applicationId,
                                                                                              java.util.Set<java.lang.String> parties)

completionStream

io.reactivex.Flowable<com.daml.ledger.javaapi.data.CompletionStreamResponse> completionStream(java.lang.String applicationId,
                                                                                              java.util.Set<java.lang.String> parties,
                                                                                              java.lang.String accessToken)

completionEnd

io.reactivex.Single<com.daml.ledger.javaapi.data.CompletionEndResponse> completionEnd()

completionEnd

io.reactivex.Single<com.daml.ledger.javaapi.data.CompletionEndResponse> completionEnd(java.lang.String accessToken)