package async_extra

An Async extension of Core_kernel.Bus. Functions that share the same name and types as those in Core_kernel.Bus are direct calls to the same.

Async.Command is Core.Command with additional Async functions.

Simple cpu usage statistics.

For communicating a dynamically chosen TCP port from a child process to its parent.

File_tail is useful for pulling data from a file that is being appended to by another process. Creating a file tail returns the reader half of a pipe whose writer half is populated by a background process that roughly does the following loop.

File_writer is a thin wrapper around Writer with a couple of extra features:

Async.Lock_file is a wrapper that provides Async equivalents for Core.Lock_file.

This module just re-exports lots of modules from Async_rpc_kernel and adds some Unix-specific wrappers in Connection (for using Reader, Writer, and Tcp). For documentation, see Rpc and Connection_intf in the Async_rpc_kernel library.

A table of sequencers indexed by key, so that at any moment for each key there is at most one job running.

Tcp supports connection to inet sockets and unix sockets. These are two different types. We use 'a Where_to_connect.t to specify a socket to connect to, where the 'a identifies the type of socket.

Access to on-disk files in parallel with serving them over a TCP connection.

A grab-bag of performance-oriented, UDP-oriented network tools. These provide some convenience, but they are more complex than basic applications require.

Unpack_sequence uses an Unpack_buffer.t to unpack a sequence of packed values coming from a string Pipe.Reader.t or a Reader.t. It can produce a pipe of upacked values or iterate a user-supplied function over the unpacked values.

Wrapper around Core.User_and_group with a deferred for_this_process / for_this_process_exn.

Like Core.Weak_hashtbl, but automatically collects keys with unused data, rather than requiring user code to call remove_keys_with_unused_data.