@type t() :: %Ariadne.Flow.ConsumeResult{
  duration_ms: non_neg_integer(),
  failure: term(),
  last_position: non_neg_integer(),
  more?: boolean(),
  processed: non_neg_integer(),
  status: :ok | :error
}