Module type Typed_tcp_intf.S

module type S = sig .. end

module Client_message: sig .. end

module Server_message: sig .. end

module Client_id: Core.Std.Unique_id 

module Server_read_result: sig .. end

type t 

val create : ?max_pending_connections:int ->
       ?verbose:bool ->
       ?log_disconnects:bool ->
       ?buffer_age_limit:[ `At_most of Core.Std.Time.Span.t | `Unlimited ] ->
       port:int ->
       auth:(Import.Unix.Inet_addr.t ->
             int -> [ `Allow | `Deny of string option ] Import.Deferred.t) ->
       unit -> t Import.Deferred.t

val listen : t ->
       Server_read_result.t Import.Pipe.Reader.t

val listen_ignore_errors : t ->
       (Client_id.t * Client_message.t) Import.Pipe.Reader.t

val close : t -> Client_id.t -> unit

val flushed_time : t ->
       Client_id.t ->
       [ `Client_not_found | `Flushed of Core.Std.Time.t Import.Deferred.t ]

val has_client_id : t -> Client_id.t -> bool

val send : t ->
       Client_id.t ->
       Server_message.t ->
       [ `Drop of exn | `Sent of Core.Std.Time.t ] Import.Deferred.t

val send_ignore_errors : t ->
       Client_id.t -> Server_message.t -> unit

val send_to_all : t -> Server_message.t -> unit

val client_addr_port : t -> Client_id.t -> (Import.Unix.Inet_addr.t * int) option