Client (p.oxbow.0.1.1.doc.oxbow.ipc.Oxbow

Sourcemodule Error : sig ... end

val 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

Source

val 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