package async_udp

  1. Overview
  2. Docs
Monadic concurrency library

Install 

dune-project
 Dependency

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

Authors

  1. J
    Jane Street Group, LLC

Maintainers

  1. J
    Jane Street developers

Sources

v0.17.0.tar.gz
sha256=018a4556494ae313ec796b816b2c8463ec4faed88520820f466bf42d849dda80

doc/async_udp/Async_udp/Config/index.html

Module Async_udp.ConfigSource

A typical receive loop implicitly calls Iobuf.flip_lo before calling its callback to prepare a packet buffer for reading by the callback and Iobuf.reset afterward to prepare for the next iteration.

It's often convenient to use the same interface for UDP, TCP, and file variants of the same protocol.

stop terminates a typical loop as soon as possible, when it becomes determined.

max_ready limits the number of receive loop iterations within an Fd.every_ready_to iteration, to prevent starvation of other Async jobs and to allow bounded busy-waiting, as on busy network sockets.

Sourcetype t = {
  1. capacity : int;
  2. init : write_buffer;
  3. stop : unit Async.Deferred.t;
  4. max_ready : int;
}
Sourceval max_ready : t -> int
Sourceval stop : t -> unit Async.Deferred.t
Sourceval init : t -> write_buffer
Sourceval capacity : t -> int
Sourceval create : ?capacity:int -> ?init:write_buffer -> ?stop:unit Async.Deferred.t -> ?max_ready:int -> unit -> t