Client (cephalopod-firehose-client.Cephalopod_firehose

type connect_error = [

]

val pp_connect_error : 
  Ppx_deriving_runtime.Format.formatter ->
  connect_error ->
  Ppx_deriving_runtime.unit

val show_connect_error : connect_error -> Ppx_deriving_runtime.string

type event =

Raw event

val pp_event : 
  Ppx_deriving_runtime.Format.formatter ->
  event ->
  Ppx_deriving_runtime.unit

val show_event : event -> Ppx_deriving_runtime.string

type t

The main client

val pp : 
  Ppx_deriving_runtime.Format.formatter ->
  t ->
  Ppx_deriving_runtime.unit

val show : t -> Ppx_deriving_runtime.string

val on_event : t -> event Cephalopod_common.Observer.t

val create : 
  sw:Eio.Switch.t ->
  stdenv:< Eio_unix.Stdenv.base.. > ->
  ws_uri:Uri.t ->
  unit ->
  (t, connect_error) result

val await : t -> unit

val shutdown : t -> unit

module Msg_event : sig ... end

Higher-level events, decoding the messages

module Subscribe : sig ... end