Package com.daml.ledger.rxjava.grpc

Class TimeClientImpl

  • All Implemented Interfaces:
    TimeClient
    public final class TimeClientImpl
extends java.lang.Object
implements TimeClient

    • Constructor Summary

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

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method 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.daml.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