View Source Membrane.RTSP.Logic (Membrane RTSP v0.6.2)

Logic for RTSP session

Summary

Functions

apply_credentials(request, uri, auth)

detect_authentication_type(response, state)

encode_digest(request, uri, options)

execute(request, state, get_response \\ true)

handle_session_id(response, state)

inject_content_length(request)

inject_session_header(request, session_id)

md5(value)

parse_response(raw_response, state)

user_agent()

Functions

apply_credentials(request, uri, auth)

@spec apply_credentials(
  Membrane.RTSP.Request.t(),
  URI.t(),
  Membrane.RTSP.Logic.State.auth_t()
) ::
  Membrane.RTSP.Request.t()

detect_authentication_type(response, state)

@spec detect_authentication_type(
  Membrane.RTSP.Response.t(),
  Membrane.RTSP.Logic.State.t()
) ::
  {:ok, Membrane.RTSP.Logic.State.t()}

encode_digest(request, uri, options)

@spec encode_digest(
  Membrane.RTSP.Request.t(),
  URI.t(),
  Membrane.RTSP.Logic.State.digest_opts()
) ::
  String.t()

execute(request, state, get_response \\ true)

@spec execute(Membrane.RTSP.Request.t(), Membrane.RTSP.Logic.State.t(), boolean()) ::
  :ok | {:ok, binary()} | {:error, reason :: any()}

handle_session_id(response, state)

@spec handle_session_id(Membrane.RTSP.Response.t(), Membrane.RTSP.Logic.State.t()) ::
  {:ok, Membrane.RTSP.Logic.State.t()} | {:error, reason :: any()}

inject_content_length(request)

@spec inject_content_length(Membrane.RTSP.Request.t()) :: Membrane.RTSP.Request.t()

inject_session_header(request, session_id)

@spec inject_session_header(Membrane.RTSP.Request.t(), binary()) ::
  Membrane.RTSP.Request.t()

md5(value)

@spec md5([String.t()]) :: String.t()

parse_response(raw_response, state)

@spec parse_response(binary(), Membrane.RTSP.Logic.State.t()) ::
  {:ok, Membrane.RTSP.Response.t(), Membrane.RTSP.Logic.State.t()}
  | {:error, reason :: any()}

user_agent()

@spec user_agent() :: binary()