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