package shared-memory-ring

  1. Overview
  2. Docs
type ('a, 'b) t
val init : ('b -> string) -> ('a, 'b) Ring.Rpc.Front.t -> ('a, 'b) t
val write : ('a, 'b) t -> (Ring.buf -> 'b) -> 'a Lwt.t Lwt.t
val push : ('a, 'b) t -> (unit -> unit) -> unit
val push_request_and_wait : ('a, 'b) t -> (unit -> unit) -> (Ring.buf -> 'b) -> 'a Lwt.t
val push_request_async : ('a, 'b) t -> (unit -> unit) -> (Ring.buf -> 'b) -> ('a Lwt.t -> unit Lwt.t) -> unit Lwt.t
val poll : ('a, 'b) t -> (Ring.buf -> 'b * 'a) -> unit
val shutdown : ('a, 'b) t -> unit
val wait_for_free : ('a, 'b) t -> int -> unit Lwt.t
val to_string : ('a, 'b) t -> string