Mailbox

#

module Postmark : sig

#

type t = {

# from	: string	;
# time	: Core_extended.Std.Time.t	;

}

#

val to_string : t -> string

#

val of_string : string -> t

#

val t_of_sexp : Sexplib.Sexp.t -> t

#

val sexp_of_t : t -> Sexplib.Sexp.t

end

#

module Message : sig

#

type t = {

# postmark	: Postmark.t	;
# email	: Email.t	;

}

#

val to_string : t -> string

#

val t_of_sexp : Sexplib.Sexp.t -> t

#

val sexp_of_t : t -> Sexplib.Sexp.t

end

#

module type With_container = sig

#

type t

#

val t_of_fd : Core.Std.In_channel.t -> t

#

val t_of_file : string -> t

#

val of_string : string -> t

#

val iter_string : t -> f:(string -> unit) -> unit

end

#

module With_lazy_list : With_container with type t = Message.t Core_extended.Std.Lazy_list.t

#

module With_seq : With_container with type t = Message.t Core_extended.Std.Lazy_sequence.t

Warning: When created from a file descriptor, the resulting mailbox can only be traversed once.

#

module With_pipe : sig

#

type t = Message.t Async.Std.Pipe.Reader.t

#

val t_of_fd : Async.Std.Fd.t -> t Async.Std.Deferred.t

#

val t_of_file : string -> t Async.Std.Deferred.t

#

val of_string : string -> t Async.Std.Deferred.t

#

val iter_string : t -> f:(string -> unit Async.Std.Deferred.t) -> unit Async.Std.Deferred.t

end

module Mailbox