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

v0.17.0.tar.gz

sha256=3edbaa62a7ea910da0d5c06974da9b2b7e14a9e2648596bc7c9f09c89970b5f8

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

Module `Rpc.Transport`Source

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

Sourcemodule Header = Async_rpc_kernel.Rpc.Transport.Header

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

Sourcemodule Handler_result = Async_rpc_kernel.Rpc.Transport.Handler_result

Sourcemodule Send_result = Async_rpc_kernel.Rpc.Transport.Send_result

Sourcetype t = {

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

}

Sourceval sexp_of_t : t -> Sexplib0.Sexp.t

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

Closes both parts of the transport.

Source

val of_reader_writer : 
  ?max_message_size:int ->
  Async_reader.t ->
  Async_writer.t ->
  t