package apero-net

  1. Overview
  2. Docs
type t
type message
type error
type message_reader = Lwt_unix.file_descr -> unit -> (message, error) Apero.Result.t Lwt.t
type message_writer = Lwt_unix.file_descr -> message -> (unit, error) Apero.Result.t Lwt.t
type replier = message -> unit Lwt.t
type event =
  1. | EventWithReplier of {
    1. msg : message;
    2. svc_id : int;
    3. sid : Id.t;
    4. reply_to : replier;
    }
  2. | Event of {
    1. msg : message;
    2. svc_id : int;
    3. sid : Id.t;
    4. reply_to : replier;
    }
val create : Config.t -> message_reader -> message_writer -> sink -> t
val start : t -> unit Lwt.t
val stop : t -> unit Lwt.t
val socket : t -> Lwt_unix.file_descr