Source file `fake_spool.ml`

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
open Core
open Async
open Async_smtp_types

type t = { send : Smtp_envelope.Routed.t -> unit Or_error.t Deferred.t }

let create ~config:_ ~send = return (Ok { send })

let add { send } ~original_msg msgs =
  match%bind Deferred.Or_error.List.iter msgs ~f:send with
  | Error e -> return (Error e)
  | Ok () -> return (Ok (Smtp_envelope.id original_msg))
;;

let flush ?timeout:_ _t = return true