let close (subs: 'a t) : unit =
    List.iter !subs ~f:(Pipe.close)