sig
type 't result = [ `Error of exn | `Ok of 't ]
type 't result_eof = [ `End_of_file | `Error of exn | `Ok of 't ]
type sockaddr = [ `Implied | `Sockaddr of Unix.sockaddr ]
val string_of_sockaddr : Netamqp_transport.sockaddr -> string
exception Error of string
class type amqp_multiplex_controller =
object
method abort_rw : unit -> unit
method alive : bool
method cancel_rd_polling : unit -> unit
method cancel_shutting_down : unit -> unit
method eff_max_frame_size : int
method event_system : Unixqueue.event_system
method getpeername : Netamqp_transport.sockaddr
method getsockname : Netamqp_transport.sockaddr
method inactivate : unit -> unit
method read_eof : bool
method reading : bool
method set_max_frame_size : int -> unit
method set_timeout : notify:(unit -> unit) -> float -> unit
method start_reading :
when_done:(Netamqp_types.frame Netamqp_transport.result_eof -> unit) ->
unit -> unit
method start_shutting_down :
when_done:(unit Netamqp_transport.result -> unit) -> unit -> unit
method start_writing :
when_done:(unit Netamqp_transport.result -> unit) ->
Netamqp_types.frame -> unit
method tls_session_props : Nettls_support.tls_session_props option
method transport_type : Netamqp_types.transport_type
method writing : bool
end
val tcp_amqp_multiplex_controller :
?close_inactive_descr:bool ->
?preclose:(unit -> unit) ->
?tls_config:(module Netsys_crypto_types.TLS_CONFIG) * string option ->
Unix.file_descr ->
Unixqueue.event_system -> Netamqp_transport.amqp_multiplex_controller
module Debug : sig val enable : bool Pervasives.ref end
end