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

Copy Markdown View Source

Incremental decoder for one draft-14 subgroup stream.

Summary

Types

t()

Functions

complete(subgroup_decoder)
push(decoder, data)

Types

t()

@type t() :: %MOQX.Protocol.MOQTDraft14.SubgroupDecoder{
  buffer: binary(),
  current_object_id: non_neg_integer(),
  header: struct() | nil,
  object_count: non_neg_integer()
}

Functions

complete(subgroup_decoder)

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

push(decoder, data)

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