package async

  1. Overview
  2. Docs
Monadic concurrency library

Install

Dune Dependency

Authors

Maintainers

Sources

async-v0.15.0.tar.gz
sha256=0d3bb21c4bed1edca25ede5e4fbc76790e22379806183846baff475281a6d6a9

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

Module Rpc.TransportSource

module Async_reader := Async_unix.Reader
module Async_writer := Async_unix.Writer
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 of_reader_writer : ?max_message_size:int -> Async_reader.t -> Async_writer.t -> t
Sourceval of_fd : ?buffer_age_limit:Async_writer.buffer_age_limit -> ?reader_buffer_size:int -> max_message_size:int -> Async_unix.Fd.t -> t
Sourcemodule Tcp : sig ... end
OCaml

Innovation. Community. Security.