package async

  1. Overview
  2. Docs
Monadic concurrency library

Install

Dune Dependency

Authors

Maintainers

Sources

async-v0.16.0.tar.gz
sha256=709041c755f4cd8740b7262e657f59c1066a8540b70c3b99368f369a1196a681

doc/async.async_rpc/Async_rpc/Rpc/Low_latency_transport/index.html

Module Rpc.Low_latency_transportSource

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

Sourcemodule 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.

Sourcemodule Reader : sig ... end
Sourcemodule 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

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

Sourceval sexp_of_t : t -> Sexplib0.Sexp.t
Sourceval close : t -> unit Async_kernel.Deferred.t

Closes both parts of the transport.

Sourceval create : ?config:Config.t -> max_message_size:int -> Async_unix.Fd.t -> t
Sourcemodule With_internal_reader : sig ... end
OCaml

Innovation. Community. Security.