Libp2p.Gossipsub.Framing (libp2p_elixir v0.9.0)

Length-delimited protobuf framing used on pubsub/gossipsub streams.

Frames are encoded as:

  • uvarint length
  • protobuf bytes (length bytes)

Summary

Functions

decode_all(buf, acc \\ [])
decode_one(buf)
encode(bin)

Functions

decode_all(buf, acc \\ [])

@spec decode_all(binary(), [binary()]) :: {[binary()], binary()}

decode_one(buf)

@spec decode_one(binary()) :: {binary(), binary()} | :more

encode(bin)

@spec encode(binary()) :: binary()