MOQX.Protocol.MOQTDraft16.SubgroupDecoder (moqx v0.8.1)

Copy Markdown View Source

Incremental decoder for one MOQT draft-16 subgroup stream.

Summary

Types

t()

Functions

complete(subgroup_decoder)
push(decoder, data)

Types

t()

@type t() :: %MOQX.Protocol.MOQTDraft16.SubgroupDecoder{
  buffer: binary(),
  header: map() | nil,
  previous_object_id: non_neg_integer() | nil,
  subgroup_id: non_neg_integer() | nil
}

Functions

complete(subgroup_decoder)

@spec complete(t()) :: :ok | {:error, {:incomplete_subgroup_stream, map()}}

push(decoder, data)

@spec push(t(), binary()) :: {:ok, t(), [map()]} | {:error, term()}