PushMessage (libp2p_ipc.Libp2p_ipc.Reader.DaemonInterface.PushMessage)

type struct_t = [

| `PushMessage_8ec8fa620071fa9f

]

type t = struct_t reader_t

type unnamed_union_t =
  Libp2p_ipc__Libp2p_ipc_capnp.MakeRPC(Capnp.RPC.None(Capnp.BytesMessage)).Reader.DaemonInterface.PushMessage.unnamed_union_t =

| PeerConnected of PeerConnected.t

| PeerDisconnected of PeerDisconnected.t

| GossipReceived of GossipReceived.t

| IncomingStream of IncomingStream.t

| StreamLost of StreamLost.t

| StreamComplete of StreamComplete.t

| StreamMessageReceived of StreamMessageReceived.t

| ResourceUpdated of ResourceUpdate.t

| Undefined of int

val get : t -> unnamed_union_t

val has_header : t -> bool

val header_get : t -> PushMessageHeader.t

val header_get_pipelined : 
  struct_t MessageWrapper.StructRef.t ->
  PushMessageHeader.struct_t MessageWrapper.StructRef.t

val of_message : 'cap message_t -> t

val of_builder : struct_t builder_t -> t