package async_rpc_kernel

  1. Overview
  2. Docs
package async_rpc_kernel
Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Module Pipe_rpc.Direct_stream_writerSource

A Direct_stream_writer.t is a simple object for responding to a Pipe_rpc query.

Sourcetype 'a t
Sourceval write : 'a t -> 'a -> [ `Flushed of unit Async_kernel.Deferred.t | `Closed ]

write t x returns `Closed if t is closed, or `Flushed d if it is open. In the open case, d is determined when the message has been flushed from the underlying Transport.Writer.t.

Sourceval write_without_pushback : 'a t -> 'a -> [ `Ok | `Closed ]
Sourceval close : _ t -> unit
Sourceval closed : _ t -> unit Async_kernel.Deferred.t
Sourceval flushed : _ t -> unit Async_kernel.Deferred.t
Sourceval is_closed : _ t -> bool
Sourcemodule Expert : sig ... end
Sourcemodule Group : sig ... end

Group of direct writers. Groups are optimized for sending the same message to multiple clients at once.

OCaml

Innovation. Community. Security.

GitHub Discord Twitter Peertube RSS
About
Changelog Releases Industrial Users Academic Users Why OCaml
Ecosystem
Packages Community Events OCaml Planet Jobs
Resources
Install OCaml Get Started Platform Tools Language Manual Standard Library API Books Exercises Papers OCaml Playground Logo
Policies
Carbon Footprint Governance Privacy Code of Conduct