let of_stream e = 
    let c = create () in
    Stream.iter ~f:(tick c) e ;
    c