package async

You can search for identifiers within the package.

in-package search v0.2.0

package async

Async
- Library async
  - Async
    
    Async_kernel_config
    
    Async_kernel_require_explicit_time_source
    
    Async_kernel_scheduler
    
    Bvar
    
    Clock_ns
    
    Condition
    
    Execution_context
    
    Gc
    
    Invariant
    
    Ivar
    
    Lazy_deferred
    
    Monad_sequence
    
    Monitor
    
    Mvar
    
    Pipe
    
    Priority
    
    Sequencer
    
    Stream
    
    Synchronous_time_source
    
    Tail
    
    Throttle
    
    Throttled
    
    Time_source
    
    Let_syntax
    
    Deferred
    
    Monad_infix
    
    Let_syntax
    
    Infix
    
    Choice
    
    Array
    
    List
    
    Map
    
    Memo
    
    Queue
    
    Sequence
    
    Set
    
    Option
    
    Result
    
    For_tests
    
    Or_error
    
    Deferred
    
    Applicative_infix
    
    Monad_infix
    
    Let_syntax
    
    List
    
    Expect_test_config
    
    IO
    
    Async_config
    
    Busy_poller
    
    Clock
    
    Dump_core_on_job_delay
    
    Fd
    
    In_thread
    
    Io_stats
    
    Io_uring_raw
    
    Io_uring_raw_singleton
    
    Io_uring
    
    Print
    
    Process
    
    Reader
    
    Require_explicit_time_source
    
    Scheduler
    
    Shutdown
    
    Signal
    
    Socket
    
    Sys
    
    Tcp
    
    Thread_safe
    
    Writer
    
    Unix
    
    Printf
    
    Overwrite_
    
    LargeFile
    
    Sexp
    
    Log
    
    For_testing
    
    Blocking
    
    Level
    
    Message
    
    Message_event
    
    Output
    
    Reader
    
    Rotation
    
    Rotation_id
    
    Global
    
    Ppx_log_syntax
    
    Ppx_log_syntax
    
    Command
    
    Enumerable_sexpable
    
    Enumerable_stringable
    
    Auto_complete
    
    Flag
    
    Anons
    
    Shape
    
    For_telemetry
    
    Deprecated
    
    Path
    
    Arg_type
    
    Param
    
    Spec
    
    Let_syntax
    
    Staged
    
    For_testing
    
    Rpc
    
    Versioned_rpc
    
    Quickcheck
    
    Generator
    
    Observer
    
    Shrinker
    
    Configure
    
    Expect_test_config
    
    IO
    
    Expect_test_config_or_error
    
    IO
- Library async.async_command
  - Async_command
    
    Enumerable_sexpable
    
    Enumerable_stringable
    
    Auto_complete
    
    Flag
    
    Anons
    
    Shape
    
    For_telemetry
    
    Deprecated
    
    Path
    
    Arg_type
    
    Param
    
    Spec
    
    Let_syntax
    
    Staged
    
    For_testing
- Library async.async_quickcheck
  - Async_quickcheck
    
    Generator
    
    Observer
    
    Shrinker
    
    Configure
- Library async.async_rpc
  - Async_rpc
    
    Rpc
    
    Transport
    
    Reader
    
    S
    
    Writer
    
    S
    
    Header
    
    Handler_result
    
    Send_result
    
    Tcp
    
    Low_latency_transport
    
    Config
    
    Reader
    
    S
    
    With_internal_reader
    
    Writer
    
    S
    
    Header
    
    Handler_result
    
    Send_result
    
    With_internal_reader
    
    Any
    
    Description
    
    How_to_recognise_errors
    
    Implementation
    
    Implementations
    
    On_exception
    
    One_way
    
    Pipe_rpc
    
    Rpc
    
    State_rpc
    
    Pipe_close_reason
    
    Connection
    
    Heartbeat_config
    
    Client_implementations
    
    For_debugging
    
    Versioned_rpc
- Library async.lock_file_async
  - Lock_file_async
    
    Nfs
    
    Flock
    
    Symlink
- Library async.log_extended
  - Log_extended
    
    For_testing
    
    Blocking
    
    Level
    
    Message
    
    Message_event
    
    Output
    
    Reader
    
    Rotation
    
    Rotation_id
    
    Global
    
    Ppx_log_syntax
    
    Console
    
    Blocking
    
    Syslog
    
    Blocking
    
    Command
- Library async.persistent_connection
  - Persistent_connection
    
    Address
    
    Closable
    
    Connection_error
    
    S
    
    Event
    
    S'
    
    Event
    
    S_rpc
    
    Event
    
    Make
    
    Event
    
    Make'
    
    Event
    
    Rpc
    
    Event
    
    Versioned_rpc
    
    Event
- Library async.unpack_sequence
  - Unpack_sequence
    
    Unpack_iter_result
    
    Unpack_result
    
    Unpack_from
- Sources
  - async
    
    async.ml
    
    async__.ml
    
    deferred_or_error_expect_test_config.ml
    
    expect_test_config.ml
    
    expect_test_config_or_error.ml
  - async.async_command
    
    async_command.ml
    
    async_command__.ml
    
    import.ml
  - async.async_quickcheck
    
    async_quickcheck.ml
    
    async_quickcheck__.ml
    
    async_quickcheck_intf.ml
  - async.async_rpc
    
    async_rpc.ml
    
    async_rpc__.ml
    
    import.ml
    
    rpc.ml
    
    rpc_transport.ml
    
    rpc_transport_low_latency.ml
  - async.lock_file_async
    
    lock_file_async.ml
  - async.log_extended
    
    log_extended.ml
  - async.persistent_connection
    
    import.ml
    
    persistent_connection.ml
    
    persistent_connection__.ml
    
    persistent_connection_intf.ml
  - async.unpack_sequence
    
    import.ml
    
    unpack_sequence.ml
    
    unpack_sequence__.ml

Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

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

Source

val of_fd : 
  ?buffer_age_limit:Async_writer.buffer_age_limit ->
  ?reader_buffer_size:int ->
  ?writer_buffer_size:int ->
  max_message_size:int ->
  Async_unix.Fd.t ->
  t

Sourcemodule Tcp : sig ... end

package async

Module Rpc.TransportSource

Module `Rpc.Transport`Source