Msg_event (cephalopod-firehose-client.Cephalopod_firehose_client.Client.Msg

type error = Cephalopod_xrpc.Decode_msg.error

val pp_error : 
  Ppx_deriving_runtime.Format.formatter ->
  error ->
  Ppx_deriving_runtime.unit

val show_error : error -> Ppx_deriving_runtime.string

type 'a t =

| E_msg of 'a
| E_closed
| E_error of error

val pp : 
  (Ppx_deriving_runtime.Format.formatter -> 'a -> Ppx_deriving_runtime.unit) ->
  Ppx_deriving_runtime.Format.formatter ->
  'a t ->
  Ppx_deriving_runtime.unit

val show : 
  (Ppx_deriving_runtime.Format.formatter -> 'a -> Ppx_deriving_runtime.unit) ->
  'a t ->
  Ppx_deriving_runtime.string

val of_event : msg:'a Cephalopod_xrpc.Base.message -> event -> 'a t