sig
type in_buffer
type out_buffer
type in_device =
[ `Async_in of Uq_engines.async_in_channel * Unixqueue.event_system
| `Buffer_in of Uq_io.in_buffer
| `Count_in of (int -> unit) * Uq_io.in_device
| `Multiplex of Uq_engines.multiplex_controller
| `Polldescr of
Netsys.fd_style * Unix.file_descr * Unixqueue.event_system ]
type out_device =
[ `Async_out of Uq_engines.async_out_channel * Unixqueue.event_system
| `Buffer_out of Uq_io.out_buffer
| `Count_out of (int -> unit) * Uq_io.out_device
| `Multiplex of Uq_engines.multiplex_controller
| `Polldescr of
Netsys.fd_style * Unix.file_descr * Unixqueue.event_system ]
type in_bdevice = [ `Buffer_in of Uq_io.in_buffer ]
type io_device =
[ `Multiplex of Uq_engines.multiplex_controller
| `Polldescr of
Netsys.fd_style * Unix.file_descr * Unixqueue.event_system ]
type string_like = Netsys_types.tbuffer
val device_supports_memory :
[ `Async_in of Uq_engines.async_in_channel * Unixqueue.event_system
| `Async_out of Uq_engines.async_out_channel * Unixqueue.event_system
| `Buffer_in of Uq_io.in_buffer
| `Buffer_out of Uq_io.out_buffer
| `Count_in of (int -> unit) * Uq_io.in_device
| `Count_out of (int -> unit) * Uq_io.out_device
| `Multiplex of Uq_engines.multiplex_controller
| `Polldescr of
Netsys.fd_style * Unix.file_descr * Unixqueue.event_system ] ->
bool
exception Line_too_long
val input_e :
[< Uq_io.in_device ] ->
Netsys_types.tbuffer -> int -> int -> int Uq_engines.engine
val really_input_e :
[< Uq_io.in_device ] ->
Netsys_types.tbuffer -> int -> int -> unit Uq_engines.engine
val input_line_e :
?max_len:int -> Uq_io.in_bdevice -> string Uq_engines.engine
val input_lines_e :
?max_len:int -> Uq_io.in_bdevice -> string list Uq_engines.engine
val eof_as_none :
'a Uq_engines.final_state -> 'a option Uq_engines.final_state
val in_obj_channel :
[< Uq_io.in_device ] -> float -> Netchannels.in_obj_channel
val output_e :
[< Uq_io.out_device ] ->
Netsys_types.tbuffer -> int -> int -> int Uq_engines.engine
val really_output_e :
[< Uq_io.out_device ] ->
Netsys_types.tbuffer -> int -> int -> unit Uq_engines.engine
val output_string_e :
[< Uq_io.out_device ] -> string -> unit Uq_engines.engine
val output_bytes_e :
[< Uq_io.out_device ] -> Bytes.t -> unit Uq_engines.engine
val output_memory_e :
[< Uq_io.out_device ] -> Netsys_mem.memory -> unit Uq_engines.engine
val output_netbuffer_e :
[< Uq_io.out_device ] -> Netbuffer.t -> unit Uq_engines.engine
val write_eof_e : [< Uq_io.out_device ] -> bool Uq_engines.engine
val copy_e :
?small_buffer:bool ->
?len:int ->
?len64:int64 ->
[< Uq_io.in_device ] -> [< Uq_io.out_device ] -> int64 Uq_engines.engine
val flush_e : [< Uq_io.out_device ] -> unit Uq_engines.engine
val out_obj_channel :
[< Uq_io.out_device ] -> float -> Netchannels.out_obj_channel
val io_obj_channel :
?start_pos_in:int ->
?start_pos_out:int ->
[< Uq_io.io_device ] -> float -> Netchannels.raw_io_channel
val shutdown_e :
?linger:float ->
[< `Async_in of Uq_engines.async_in_channel * Unixqueue.event_system
| `Async_out of Uq_engines.async_out_channel * Unixqueue.event_system
| `Buffer_in of Uq_io.in_buffer
| `Buffer_out of Uq_io.out_buffer
| `Count_in of (int -> unit) * Uq_io.in_device
| `Count_out of (int -> unit) * Uq_io.out_device
| `Multiplex of Uq_engines.multiplex_controller
| `Polldescr of
Netsys.fd_style * Unix.file_descr * Unixqueue.event_system ] ->
unit Uq_engines.engine
val inactivate :
[< `Async_in of Uq_engines.async_in_channel * Unixqueue.event_system
| `Async_out of Uq_engines.async_out_channel * Unixqueue.event_system
| `Buffer_in of Uq_io.in_buffer
| `Buffer_out of Uq_io.out_buffer
| `Count_in of (int -> unit) * Uq_io.in_device
| `Count_out of (int -> unit) * Uq_io.out_device
| `Multiplex of Uq_engines.multiplex_controller
| `Polldescr of
Netsys.fd_style * Unix.file_descr * Unixqueue.event_system ] ->
unit
val create_in_buffer :
?small_buffer:bool -> [< Uq_io.in_device ] -> Uq_io.in_buffer
val in_buffer_length : Uq_io.in_buffer -> int
val in_buffer_blit :
Uq_io.in_buffer -> int -> Netsys_types.tbuffer -> int -> int -> unit
val in_buffer_fill_e : Uq_io.in_buffer -> bool Uq_engines.engine
val create_out_buffer :
?small_buffer:bool ->
max:int option -> [< Uq_io.out_device ] -> Uq_io.out_buffer
val filter_out_buffer :
max:int option ->
Netchannels.io_obj_channel -> [< Uq_io.out_device ] -> Uq_io.out_buffer
end
