@spec create_pull_point(ExOxvif.Session.t(), keyword()) ::
  {:ok, ExOxvif.Events.Subscription.t()} | {:error, ExOxvif.Error.t()}

Create a pull-point subscription.

Options:

• :filter - a topic expression, e.g. "tns1:VideoSource/MotionAlarm"
• :termination - initial lifetime in milliseconds (device default if omitted)

@spec pull_messages(
  ExOxvif.Session.t(),
  ExOxvif.Events.Subscription.t() | String.t(),
  keyword()
) ::
  {:ok, [ExOxvif.Events.Message.t()]} | {:error, ExOxvif.Error.t()}

Pull pending messages, waiting on the device for up to :wait milliseconds (default 5000) for at least one.

Options: :wait, :max_messages (default 100). The call :timeout defaults to :wait plus 15 seconds.

@spec renew(
  ExOxvif.Session.t(),
  ExOxvif.Events.Subscription.t() | String.t(),
  pos_integer(),
  ExOxvif.call_opts()
) :: {:ok, String.t()} | {:error, ExOxvif.Error.t()}

Extend a subscription to termination milliseconds from now. Returns the new termination time reported by the device.

@spec unsubscribe(
  ExOxvif.Session.t(),
  ExOxvif.Events.Subscription.t() | String.t(),
  ExOxvif.call_opts()
) :: :ok | {:error, ExOxvif.Error.t()}

Cancel a subscription.