package oxbow

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

Module Oxbow_ipc.ClientSource

Sourcemodule Error : sig ... end
Sourceval send : env:Eio_unix.Stdenv.base -> ?seat:string -> ?socket:string -> Request.Body.t -> (Yojson.Safe.t option, Error.t) result

send ~env ?seat ?socket body sends body as a one-line JSON request over the oxbow socket and awaits the reply; socket overrides the resolved socket path; seat overrides the primary-seat target.

Effects: I/O

Sourceval subscribe : env:Eio_unix.Stdenv.base -> ?socket:string -> ?output:string -> kinds:Record.t list -> (string -> unit) -> (unit, Error.t) result

subscribe ~env ?socket ?output ~kinds f opens a subscribe stream over the oxbow socket and calls f with each event line until either side closes; kinds empty for all kinds, output restricts output-keyed kinds.

Effects: I/O; blocks until the stream ends