Legend:
Library
Module
Module type
Parameter
Class
Class type
Library
Module
Module type
Parameter
Class
Class type
package shuttle
Legend:
Library
Module
Module type
Parameter
Class
Class type
Library
Module
Module type
Parameter
Class
Class type
Alternative to Async_unix.Writer, based on the low latency transport in async_rpc.
val sexp_of_t : t -> Ppx_sexp_conv_lib.Sexp.tval create :
?initial_buffer_size:int ->
?write_timeout:Core.Time_ns.Span.t ->
Async_unix.Fd.t ->
tcreate ?initial_buffer_size ?max_buffer_size ?write_timeout fd creates a new writer.
The writer doesn't flush automatically and the user is responsible for calling flush, which triggers a write system call if needed.
val is_closed : t -> boolval is_open : t -> boolval close_started : t -> unit Async_kernel.Deferred.tval close_finished : t -> unit Async_kernel.Deferred.tval schedule_bigstring : t -> ?pos:int -> ?len:int -> Core.Bigstring.t -> unitschedule_bigstring schedules a bigstring to be written on the next flush. It is not safe to modify this bigstring until the writer has been flushed, or closed.
val write_string : t -> ?pos:int -> ?len:int -> string -> unitwrite_string copies the string into the writer's internal buffer. The string will surface the next time the writer schedules a write.
val close : t -> unit Async_kernel.Deferred.tclose will close the underlying file descriptor after waiting for the writer to be flushed.
val flush : t -> unitflush will schedule a write system call if one is needed.
val flushed : t -> unit Async_kernel.Deferred.tflushed t f deferred that will get resolved when all prior writes have finished.