Up

module Fake_spool

: sig
#
type t
#
val create : config:Config.t -> send:(Types.Envelope_with_next_hop.t -> unit Core.Std.Or_error.t Async.Std.Deferred.t) -> t Core.Std.Or_error.t Async.Std.Deferred.t
#
val add : t -> original_msg:Types.Envelope.t -> Types.Envelope_with_next_hop.t list -> Types.Envelope.Id.t Core.Std.Or_error.t Async.Std.Deferred.t
#
val flush : ?timeout:unit Async.Std.Deferred.t -> t -> bool Async.Std.Deferred.t
end