t() :: %Gnat.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()},
  inbox: String.t() | nil,
  max_in_flight: non_neg_integer(),
  sub_subject: String.t(),
  subject: String.t(),
  task_supervisor_pid: pid()
}