com.daml.ledger.rxjava.grpc

Class TimeClientImpl

java.lang.Object

com.daml.ledger.rxjava.grpc.TimeClientImpl

All Implemented Interfaces:

TimeClient

public final class TimeClientImpl
extends java.lang.Object
implements TimeClient

Constructor Summary

Constructors

Constructor and Description
TimeClientImpl(java.lang.String ledgerId, io.grpc.Channel channel, com.digitalasset.grpc.adapter.ExecutionSequencerFactory sequencerFactory, java.util.Optional<java.lang.String> accessToken)

Method Summary

Modifier and Type	Method and Description
io.reactivex.Flowable<java.time.Instant>	getTime()
io.reactivex.Flowable<java.time.Instant>	getTime(java.lang.String accessToken)
io.reactivex.Single<com.google.protobuf.Empty>	setTime(java.time.Instant currentTime, java.time.Instant newTime)
io.reactivex.Single<com.google.protobuf.Empty>	setTime(java.time.Instant currentTime, java.time.Instant newTime, java.lang.String accessToken)

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeClientImpl

public TimeClientImpl(java.lang.String ledgerId,
                      io.grpc.Channel channel,
                      com.digitalasset.grpc.adapter.ExecutionSequencerFactory sequencerFactory,
                      java.util.Optional<java.lang.String> accessToken)

Method Detail

setTime

public io.reactivex.Single<com.google.protobuf.Empty> setTime(java.time.Instant currentTime,
                                                              java.time.Instant newTime)

Specified by:

setTime in interface TimeClient

setTime

public io.reactivex.Single<com.google.protobuf.Empty> setTime(java.time.Instant currentTime,
                                                              java.time.Instant newTime,
                                                              java.lang.String accessToken)

Specified by:

setTime in interface TimeClient

getTime

public io.reactivex.Flowable<java.time.Instant> getTime()

Specified by:

getTime in interface TimeClient

getTime

public io.reactivex.Flowable<java.time.Instant> getTime(java.lang.String accessToken)

Specified by:

getTime in interface TimeClient