sig
  type ('a, 'b, 'c) t =
      Run of Async.Std.Writer.buffer_age_limit option *
        (('a, 'b) Hub.t -> 'c Async.Std.Deferred.t)
end