graph_reachability

hydro_test::local::graph_reachability

Function graph_reachability 

Source 
pub fn graph_reachability<'a>(
    process: &Process<'a>,
    roots: Stream<u32, Process<'a>, Unbounded>,
    edges: Stream<(u32, u32), Process<'a>, Unbounded>,
) -> Stream<u32, Process<'a>, Unbounded, NoOrder>