Package 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 Object
implements TimeClient

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

TimeClientImpl

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

Method Details

setTime

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

Specified by:

setTime in interface TimeClient

setTime

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

Specified by:

setTime in interface TimeClient

getTime

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

Specified by:

getTime in interface TimeClient

getTime

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

Specified by:

getTime in interface TimeClient