Make.Timer_transport
val send :
t ->
recipient:Trivial_peer.t ->
Message.t ->
unit Core_kernel.Or_error.t Async_kernel.Deferred.t
val listen : t -> me:Trivial_peer.t -> Message.t Pipe_lib.Linear_pipe.Reader.t
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:Trivial_peer.t -> unit