ocamlnet 4.1.9-2 · OCaml Package

exception Closed_channel

exception Broken_communication

exception Watchdog_timeout

exception Timeout

exception Addressing_method_not_supported

exception Cancelled

type !'t engine_state = [

| `Aborted
| `Done of 't
| `Error of exn
| `Working of int

]

type !'t final_state = [

| `Aborted
| `Done of 't
| `Error of exn

]

val string_of_state : 'a engine_state -> string

class type !'t engine = object ... end

class !'t delegate_engine : 't engine -> 't engine

val when_state : 
  ?is_done:('a -> unit) ->
  ?is_error:(exn -> unit) ->
  ?is_aborted:(unit -> unit) ->
  ?is_progressing:(int -> unit) ->
  'a engine ->
  unit

class !'a signal_engine : Unixqueue.event_system -> object ... end

val signal_engine : 
  Unixqueue.event_system ->
  'a engine * ('a final_state -> unit)

class ['a, !'b] map_engine : map_done:('a ->
  'b engine_state) -> ?map_error:(exn ->
  'b engine_state) -> ?map_aborted:(unit ->
  'b engine_state) -> ?propagate_working:bool -> 'a engine -> ['a, 'b] engine

val map_engine : 
  map_done:('a -> 'b engine_state) ->
  ?map_error:(exn -> 'b engine_state) ->
  ?map_aborted:(unit -> 'b engine_state) ->
  ?propagate_working:bool ->
  'a engine ->
  'b engine

class ['a, !'b] fmap_engine : 'a engine -> ('a final_state -> 'b final_state) -> ['a, 'b] engine

val fmap_engine : 'a engine -> ('a final_state -> 'b final_state) -> 'b engine

class !'a meta_engine : 'a engine -> 'a engine

val meta_engine : 'a engine -> 'a final_state engine

class !'t epsilon_engine : 't engine_state -> Unixqueue.event_system -> 't engine

val epsilon_engine : 't engine_state -> Unixqueue.event_system -> 't engine

class ['a, !'b] seq_engine : 'a engine -> ('a -> 'b engine) -> ['a, 'b] engine

val seq_engine : 'a engine -> ('a -> 'b engine) -> 'b engine

class ['a, !'b] qseq_engine : 'a engine -> ('a -> 'b engine) -> ['a, 'b] engine

val qseq_engine : 'a engine -> ('a -> 'b engine) -> 'b engine

class !'a stream_seq_engine : 'a -> ('a -> 'a engine) Stream.t -> Unixqueue.event_system -> 'a engine

val stream_seq_engine : 
  'a ->
  ('a -> 'a engine) Stream.t ->
  Unixqueue.event_system ->
  'a engine

class [!'a, !'b] sync_engine : 'a engine -> 'b engine -> ['a, 'b] engine

val sync_engine : 'a engine -> 'b engine -> ('a * 'b) engine

class ['a, !'b] msync_engine : 'a engine list -> ('a ->
  'b ->
  'b) -> 'b -> Unixqueue.event_system -> ['a, 'b] engine

val msync_engine : 
  'a engine list ->
  ('a -> 'b -> 'b) ->
  'b ->
  Unixqueue.event_system ->
  'b engine

class !'a delay_engine : float -> (unit -> 'a engine) -> Unixqueue.event_system -> 'a engine

val delay_engine : 
  float ->
  (unit -> 'a engine) ->
  Unixqueue.event_system ->
  'a engine

class !'a timeout_engine : float -> exn -> 'a engine -> 'a engine

val timeout_engine : float -> exn -> 'a engine -> 'a engine

class watchdog : float -> 'a engine -> engine

val watchdog : float -> 'a engine -> unit engine

class type !'a serializer_t = object ... end

class !'a serializer : Unixqueue.event_system -> 'a serializer_t

val serializer : Unixqueue.event_system -> 'a serializer_t

class type !'a prioritizer_t = object ... end

class !'a prioritizer : Unixqueue.event_system -> 'a prioritizer_t

val prioritizer : Unixqueue.event_system -> 'a prioritizer_t

class type !'a cache_t = object ... end

class !'a cache : (Unixqueue.event_system ->
  'a engine) -> Unixqueue.event_system -> 'a cache_t

val cache : 
  (Unixqueue.event_system -> 'a engine) ->
  Unixqueue.event_system ->
  'a cache_t

class !'t engine_mixin : 't engine_state -> Unixqueue.event_system -> object ... end

module Operators : sig ... end

class poll_engine : ?extra_match:(exn ->
  bool) -> (Unixqueue.operation * float) list -> Unixqueue.event_system -> object ... end

class !'a input_engine : (Unix.file_descr ->
  'a) -> Unix.file_descr -> float -> Unixqueue.event_system -> 'a engine

class !'a output_engine : (Unix.file_descr ->
  'a) -> Unix.file_descr -> float -> Unixqueue.event_system -> 'a engine

class poll_process_engine : ?period:float -> pid:int -> Unixqueue.event_system -> engine

class type async_out_channel = object ... end

class type async_in_channel = object ... end

class type async_out_channel_engine = object ... end

type copy_task = [

| `Bidirectional of Unix.file_descr * Unix.file_descr
| `Tridirectional of Unix.file_descr * Unix.file_descr * Unix.file_descr
| `Uni_socket of Unix.file_descr * Unix.file_descr
| `Unidirectional of Unix.file_descr * Unix.file_descr

]

class type async_in_channel_engine = object ... end

class type multiplex_controller = object ... end

exception Mem_not_supported

class type datagram_multiplex_controller = object ... end

type onshutdown_out_spec = [

| `Action of async_out_channel_engine -> multiplex_controller -> unit engine_state -> unit
| `Ignore
| `Initiate_shutdown

]

type onshutdown_in_spec = [

| `Action of async_in_channel_engine -> multiplex_controller -> unit engine_state -> unit
| `Ignore
| `Initiate_shutdown

]

type inetspec = [

| `Sock_inet of Unix.socket_type * Unix.inet_addr * int
| `Sock_inet_byname of Unix.socket_type * string * int

]

type sockspec = [

| `Sock_inet of Unix.socket_type * Unix.inet_addr * int
| `Sock_inet_byname of Unix.socket_type * string * int
| `Sock_unix of Unix.socket_type * string

]

type connect_address = [

| `Command of string * (int -> Unixqueue.event_system -> unit)
| `Socket of sockspec * connect_options
| `W32_pipe of Netsys_win32.pipe_mode * string

]

and connect_options = {

conn_bind : sockspec option;

}

type connect_status = [

| `Command of Unix.file_descr * int
| `Socket of Unix.file_descr * sockspec
| `W32_pipe of Unix.file_descr

]

class type client_endpoint_connector = object ... end

type listen_address = [

| `Socket of sockspec * listen_options
| `W32_pipe of Netsys_win32.pipe_mode * string * listen_options

]

and listen_options = {

lstn_backlog : int;
lstn_reuseaddr : bool;

}

class type server_endpoint_acceptor = object ... end

class type server_endpoint_listener = object ... end

type datagram_type = [

| `Inet6_udp
| `Inet_udp
| `Unix_dgram

]

class type wrapped_datagram_socket = object ... end

class type datagram_socket_provider = object ... end

module Debug : sig ... end

package ocamlnet