t() :: %Nats.Streaming.Subscription{
  ack_subject: String.t(),
  ack_wait_in_sec: non_neg_integer(),
  client_id: String.t() | nil,
  client_name: atom(),
  connection_pid: pid() | nil,
  consuming_function: {atom(), atom()},
  durable_name: String.t() | nil,
  inbox: String.t() | nil,
  max_in_flight: non_neg_integer(),
  queue_group: String.t() | nil,
  start_position:
    :first
    | :last_received
    | :new_only
    | :sequence_start
    | :time_delta_start
    | nil,
  start_sequence: non_neg_integer() | nil,
  start_time_delta: integer() | nil,
  sub_subject: String.t(),
  subject: String.t(),
  task_supervisor_pid: pid()
}