@spec authorization_token(binary(), non_neg_integer()) :: binary()

@spec client_setup(map()) :: binary()

@spec decode_control(binary()) ::
  {:ok, [{non_neg_integer(), binary()}], binary()} | {:error, term()}

@spec decode_publish_done(binary()) :: {:ok, struct()} | {:error, term()}

@spec decode_publish_namespace_cancel(binary()) :: {:ok, struct()} | {:error, term()}

@spec decode_publish_namespace_error(binary()) :: {:ok, struct()} | {:error, term()}

@spec decode_publish_namespace_ok(binary()) :: {:ok, struct()} | {:error, term()}

@spec decode_server_setup(binary()) :: {:ok, non_neg_integer()} | {:error, term()}

@spec decode_subgroup_header(binary()) ::
  {:ok, struct(), binary()} | :more | {:error, term()}

@spec decode_subgroup_object(binary()) ::
  {:ok, map(), binary()} | :more | {:error, term()}

@spec decode_subgroup_object(struct(), non_neg_integer(), binary()) ::
  {:ok, struct(), binary()} | :more | {:error, term()}

@spec decode_subscribe(binary()) :: {:ok, struct()} | {:error, term()}

@spec decode_subscribe_error(binary()) :: {:ok, struct()} | {:error, term()}

@spec decode_subscribe_ok(binary()) :: {:ok, map()} | {:error, term()}

@spec decode_unsubscribe(binary()) :: {:ok, struct()} | {:error, term()}

@spec decode_varint(binary()) :: {:ok, non_neg_integer(), binary()} | :more

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

@spec encode_subgroup(non_neg_integer(), MOQX.Object.t()) :: binary()

@spec encode_varint(non_neg_integer()) :: binary()

@spec subscribe(non_neg_integer(), MOQX.TrackRef.t(), keyword()) :: binary()

@spec unsubscribe(non_neg_integer()) :: binary()