package async

You can search for identifiers within the package.

in-package search v0.2.0

Monadic concurrency library

Install

Dune Dependency

github.com Readme Changelog MIT License Edit opam file Versions (6)

Authors

J

Jane Street Group, LLC

Maintainers

J

Jane Street developers

Sources

async-v0.14.0.tar.gz

sha256=74f2b7b01ce3b92289cc7a68cd3ae53885c763cedd320d27949d585e5c13dc64

md5=9f80cfb72e3defcc9fca50f67e23e93c

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

Module `Rpc.Low_latency_transport`

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