Fake_timer_transport (distributed_dsl.Distributed_dsl.Fake_timer

Parameters

module Message : sig ... end

module Message_delay : Message_delay_intf with type message := Message.t

module Peer : sig ... end

type t

val send : 
  t ->
  recipient:Peer.t ->
  Message.t ->
  unit Core_kernel.Or_error.t Async_kernel.Deferred.t

val listen : t -> me:Peer.t -> Message.t Pipe_lib.Linear_pipe.Reader.t

type tok

val equal_tok : tok -> tok -> bool

val wait : 
  t ->
  Core_kernel.Time.Span.t ->
  tok * [ `Cancelled | `Finished ] Async_kernel.Deferred.t

val cancel : t -> tok -> unit

include Temporal_intf with type t := t

val create : now:Core_kernel.Time.Span.t -> t

val tick_forwards : t -> unit Async_kernel.Deferred.t

val stop_listening : t -> me:Peer.t -> unit