package async

You can search for identifiers within the package.

in-package search v0.2.0

async
- Async
  - Command
  - Deferred
    
    Or_error
    
    Expect_test_config
    
    IO
  - Expect_test_config
    
    IO
  - Expect_test_config_or_error
    
    IO
  - Ppx_log_syntax
    
    Global
    
    No_global
    
    Ppx_log_syntax
    
    Global
  - Quickcheck
async.async_command
- Async_command
  - Staged
async.async_quickcheck
- Async_quickcheck
  - Configure
    
    Config
async.async_rpc
- Async_rpc
  - Rpc
    
    Connection
    
    Low_latency_transport
    
    Config
    
    Reader
    
    With_internal_reader
    
    With_internal_reader
    
    Writer
    
    Transport
    
    Reader
    
    Tcp
    
    Writer
async.lock_file_async
- Lock_file_async
  - Flock
  - Nfs
  - Symlink
async.log_extended
- Log_extended
  - Command
  - Console
    
    Blocking
  - Syslog
    
    Blocking
async.persistent_connection
- Persistent_connection
  - Make
    
    Conn
    
    Event
  - Rpc
    
    Event
  - S
    
    Event
  - S_rpc
    
    Event
  - Versioned_rpc
    
    Event
async.unpack_sequence
- Unpack_sequence

Legend:
Library
Module
Module type
Parameter
Class
Class type

This module implements a RPC transport optimized for low-latency.

module Config : sig ... end

All the following create functions take a max_message_size argument in addition to a Config.t. The final max_message_size will be the min of both.

The rationale for this is that max_message_size is more a property of the protocol and should be specified by the programmer, while other configuration parameters are for tuning purposes.

module Reader : sig ... end

module Writer : sig ... end

include module type of struct include Async_rpc_kernel.Rpc.Transport end
  with module Reader := Async_rpc_kernel.Rpc.Transport.Reader
  with module Writer := Async_rpc_kernel.Rpc.Transport.Writer

module Header = Async_rpc_kernel.Rpc.Transport.Header

Binary headers containing message lengths. All transports should use this to ensure binary compatibility.

module Handler_result = Async_rpc_kernel.Rpc.Transport.Handler_result

module Send_result = Async_rpc_kernel.Rpc.Transport.Send_result

type t = {

reader : Async_rpc_kernel.Rpc.Transport.Reader.t;
writer : Async_rpc_kernel.Rpc.Transport.Writer.t;

}

val sexp_of_t : t -> Sexplib0.Sexp.t

val close : t -> unit Async_kernel.Deferred.t

Closes both parts of the transport.

val create : ?config:Config.t -> max_message_size:int -> Async_unix.Fd.t -> t

module With_internal_reader : sig ... end