uwt 0.3.2 · OCaml Package

type t

val close : t -> Int_result.unit

val close_noerr : t -> unit

val close_wait : t -> unit Lwt.t

val is_active : t -> bool

val ref' : t -> unit

val unref : t -> unit

val has_ref : t -> bool

val to_handle : t -> Handle.t

val is_readable : t -> bool

val is_writable : t -> bool

val read_start : t -> cb:(Stdlib.Bytes.t uv_result -> unit) -> Int_result.unit

val read_start_exn : t -> cb:(Stdlib.Bytes.t uv_result -> unit) -> unit

val read_stop : t -> Int_result.unit

val read_stop_exn : t -> unit

val read : ?pos:int -> ?len:int -> t -> buf:bytes -> int Lwt.t

val read_ba : ?pos:int -> ?len:int -> t -> buf:buf -> int Lwt.t

val write_queue_size : t -> int

val try_write : ?pos:int -> ?len:int -> t -> buf:bytes -> Int_result.int

val try_write_ba : ?pos:int -> ?len:int -> t -> buf:buf -> Int_result.int

val try_write_string : 
  ?pos:int ->
  ?len:int ->
  t ->
  buf:string ->
  Int_result.int

val write : ?pos:int -> ?len:int -> t -> buf:bytes -> unit Lwt.t

val write_string : ?pos:int -> ?len:int -> t -> buf:string -> unit Lwt.t

val write_ba : ?pos:int -> ?len:int -> t -> buf:buf -> unit Lwt.t

val write_raw : ?pos:int -> ?len:int -> t -> buf:bytes -> unit Lwt.t

val write_raw_string : ?pos:int -> ?len:int -> t -> buf:string -> unit Lwt.t

val write_raw_ba : ?pos:int -> ?len:int -> t -> buf:buf -> unit Lwt.t

val try_writev : t -> Iovec_write.t list -> Int_result.int

val writev : t -> Iovec_write.t list -> unit Lwt.t

val writev_emul : t -> Iovec_write.t list -> unit Lwt.t

val writev_raw : t -> Iovec_write.t list -> unit Lwt.t

val listen : 
  t ->
  max:int ->
  cb:(t -> Int_result.unit -> unit) ->
  Int_result.unit

val listen_exn : t -> max:int -> cb:(t -> Int_result.unit -> unit) -> unit

val shutdown : t -> unit Lwt.t

val set_blocking : t -> bool -> Int_result.unit

val get_send_buffer_size : t -> Int_result.int

val get_send_buffer_size_exn : t -> int

val get_recv_buffer_size : t -> Int_result.int

val get_recv_buffer_size_exn : t -> int

val set_send_buffer_size : t -> int -> Int_result.unit

val set_send_buffer_size_exn : t -> int -> unit

val set_recv_buffer_size : t -> int -> Int_result.unit

val set_recv_buffer_size_exn : t -> int -> unit

val fileno : t -> Unix.file_descr uv_result

val fileno_exn : t -> Unix.file_descr

val to_stream : t -> Stream.t

val init : ?ipc:bool -> unit -> t

val openpipe : ?ipc:bool -> Unix.file_descr -> t uv_result

val openpipe_exn : ?ipc:bool -> Unix.file_descr -> t

val bind : t -> path:string -> Int_result.unit

val bind_exn : t -> path:string -> unit

val getsockname : t -> string uv_result

val getsockname_exn : t -> string

val getpeername : t -> string uv_result

val getpeername_exn : t -> string

val pending_instances : t -> int -> Int_result.unit

val pending_instances_exn : t -> int -> unit

val accept : t -> t uv_result

val accept_exn : t -> t

val accept_raw : server:t -> client:t -> Int_result.unit

val accept_raw_exn : server:t -> client:t -> unit

val pending_count : t -> Int_result.int

val pending_count_exn : t -> int

type ipc_result =

| Ipc_error of error
| Ipc_none
| Ipc_tcp of Tcp.t
| Ipc_udp of Udp.t
| Ipc_pipe of t

val accept_ipc : t -> ipc_result

val write2 : ?pos:int -> ?len:int -> buf:bytes -> send:Tcp.t -> t -> unit Lwt.t

val write2_ba : 
  ?pos:int ->
  ?len:int ->
  buf:buf ->
  send:Tcp.t ->
  t ->
  unit Lwt.t

val write2_string : 
  ?pos:int ->
  ?len:int ->
  buf:string ->
  send:Tcp.t ->
  t ->
  unit Lwt.t

val write2_pipe : 
  ?pos:int ->
  ?len:int ->
  buf:bytes ->
  send:t ->
  t ->
  unit Lwt.t

val write2_pipe_ba : 
  ?pos:int ->
  ?len:int ->
  buf:buf ->
  send:t ->
  t ->
  unit Lwt.t

val write2_pipe_string : 
  ?pos:int ->
  ?len:int ->
  buf:string ->
  send:t ->
  t ->
  unit Lwt.t

val write2_udp : 
  ?pos:int ->
  ?len:int ->
  buf:bytes ->
  send:Udp.t ->
  t ->
  unit Lwt.t

val write2_udp_ba : 
  ?pos:int ->
  ?len:int ->
  buf:buf ->
  send:Udp.t ->
  t ->
  unit Lwt.t

val write2_udp_string : 
  ?pos:int ->
  ?len:int ->
  buf:string ->
  send:Udp.t ->
  t ->
  unit Lwt.t

val connect : t -> path:string -> unit Lwt.t

val with_pipe : ?ipc:bool -> (t -> 'a Lwt.t) -> 'a Lwt.t

val with_connect : path:string -> (t -> 'a Lwt.t) -> 'a Lwt.t

val with_open : ?ipc:bool -> Unix.file_descr -> (t -> 'a Lwt.t) -> 'a Lwt.t

type chmod =

| Pipe_readable
| Pipe_writeable
| Pipe_readable_writeable

val chmod : t -> chmod -> Int_result.unit

val chmod_exn : t -> chmod -> unit

package uwt