package async_unix

  1. Overview
  2. Docs
Monadic concurrency library

Install

Dune Dependency

Authors

Maintainers

Sources

v0.17.0.tar.gz
sha256=814d3a9997ec1316b8b2a601b24471740641647a25002761f7df7869c3ac9e33

doc/async_unix/Async_unix/index.html

Module Async_unixSource

Sourcemodule Async_config : sig ... end
Sourcemodule Busy_poller : sig ... end
Sourcemodule Clock : sig ... end

A Clock based on Core.Time.

Sourcemodule Dump_core_on_job_delay : sig ... end

Dump core if jobs are delayed, to get additional debug information when running on UNIX systems that support core dumps.

Sourcemodule Fd : sig ... end

An Fd.t is a wrapper around a Unix file descriptor, with additional information about the kind of file descriptor and logic to ensure that we don't use a file descriptor that has been closed, or close a file descriptor that is in use.

Sourcemodule In_thread : sig ... end

The In_thread module has functions for interaction between the Async world and other (kernel) threads. The name is to remind us to think about threads and race conditions.

Sourcemodule Io_stats : sig ... end

Gives stats about system IO usage.

Sourcemodule Io_uring_raw : sig ... end
Sourcemodule Io_uring_raw_singleton : sig ... end

This module contains a singleton that wraps over different possible drivers of the Io_uring_raw. Currently it only supports an Eventfd driver or not using Io_uring at all. The underlying implementation can be picked via the io_uring_mode async config.

Sourcemodule Io_uring : sig ... end
Sourcemodule Print : sig ... end

Non-blocking, Async-friendly print functions.

Sourcemodule Process : sig ... end

Async.Process is for creating child processes of the current process, and communicating with children via their stdin, stdout, and stderr. Async.Process is the Async analog of Core_unix.create_process and related functions.

Sourcemodule Reader : sig ... end

Reader is Async's main API for buffered input from a file descriptor. It is the analog of Stdio.In_channel.

Deprecates functions that use wall-clock time, so that code must be explicit about what time source is used.

Sourcemodule Scheduler : sig ... end

Dispatches and monitors Async processes.

Sourcemodule Shutdown : sig ... end

For shutting down an Async program.

Sourcemodule Signal : sig ... end

Signal handling.

Sourcemodule Socket : sig ... end
Sourcemodule Sys : sig ... end

This module overrides everything in the Core.Sys module that might block. Functions do the same thing as their counterparts in Core.Sys, but instead return deferreds. For a description of their semantics see the documentation for the Core.Sys module.

Sourcemodule Tcp : sig ... end

Tcp supports connection to inet sockets and unix sockets.

Sourcemodule Thread_safe : sig ... end

The Thread_safe module has functions that are safe to call from threads outside Async, such as the ones spawned by In_thread.run.

Sourcemodule Writer : sig ... end
Sourcemodule Unix : sig ... end
Sourceval after : Async_unix__.Import.Time.Span.t -> unit Async_kernel.Deferred.t
Sourceval at : Async_unix__.Import.Time.t -> unit Async_kernel.Deferred.t
Sourceval every : ?start:unit Async_kernel.Deferred.t -> ?stop:unit Async_kernel.Deferred.t -> ?continue_on_error:bool -> Async_unix__.Import.Time.Span.t -> (unit -> unit) -> unit
Sourceval with_timeout : Async_unix__.Import.Time.Span.t -> 'a Async_kernel.Deferred.t -> 'a Clock.Or_timeout.t Async_kernel.Deferred.t
Sourceval schedule : ?monitor:Async_kernel.Monitor.t -> ?priority:Async_kernel.Priority.t -> (unit -> unit) -> unit
Sourceval shutdown : ?force:unit Async_kernel.Deferred.t -> int -> unit
Sourceval within : ?monitor:Async_kernel.Monitor.t -> ?priority:Async_kernel.Priority.t -> (unit -> unit) -> unit
Sourcemodule Printf : sig ... end

Shadow blocking functions in Core.Printf to prevent their unintentional use.

include sig ... end
Sourcemodule Overwrite_ : sig ... end
Sourceval close_in_noerr : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval close_in : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval close_out_noerr : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval close_out : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval eprintf : ('a, unit, string, unit) format4 -> 'a
Sourceval flush_all : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval flush : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval fprintf : Writer.t -> ('a, unit, string, unit) format4 -> 'a
Sourceval ifprintf : 'a -> ('b, 'a, 'c, unit) format4 -> 'b
Sourceval in_channel_length : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval input_binary_int : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval input_byte : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval input_char : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval input_line : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval input_lines : ?fix_win_eol:'a -> [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval input : [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval input_value : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval open_in_bin : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval open_in_gen : [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval open_in : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval open_out_bin : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval open_out_gen : [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval open_out : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval out_channel_length : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval output_binary_int : [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval output_byte : [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval output_char : [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval output : [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval output_string : [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval output_value : [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval pos_in : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval pos_out : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval prerr_char : char -> unit
Sourceval prerr_endline : string -> unit
Sourceval prerr_float : float -> unit
Sourceval prerr_int : int -> unit
Sourceval prerr_newline : unit -> unit
Sourceval prerr_string : string -> unit
Sourceval print_char : char -> unit
Sourceval print_endline : string -> unit
Sourceval print_float : float -> unit
Sourceval printf : ('a, unit, string, unit) format4 -> 'a
Sourceval print_int : int -> unit
Sourceval print_newline : unit -> unit
Sourceval print_s : ?mach:unit -> Sexplib.Sexp.t -> unit
Sourceval print_string : string -> unit
Sourceval read_float : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval read_int : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval read_line : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval read_lines : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval read_wrap : ?binary:'a -> f:'b -> [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval really_input : [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval seek_in : [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval seek_out : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval set_binary_mode_in : [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval set_binary_mode_out : [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval write_lines : [< `This_is_async__Think_about_blocking ] -> [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval write_wrap : ?binary:'a -> f:'b -> [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval eprint_s : [< `This_is_async__Think_about_blocking ] -> [> `This_is_async__Think_about_blocking ]
Sourceval eprint_s_nonblocking : ?mach:unit -> Sexplib.Sexp.t -> unit
Sourcemodule LargeFile : sig ... end
Sourcemodule Sexp : sig ... end
Sourceval exit : ?force:unit Async_kernel.Deferred.t -> int -> 'a Async_kernel.Deferred.t
OCaml

Innovation. Community. Security.