multi_location_test

Function multi_location_test 

Source
pub async fn multi_location_test<'a, T, C, O, R>(
    thunk: impl FnOnce(&FlowBuilder<'a>, &Process<'a, ()>) -> Stream<T, Process<'a>, Unbounded, O, R>,
    check: impl FnOnce(Pin<Box<dyn Stream<Item = T>>>) -> C,
)
where T: Serialize + DeserializeOwned + 'static, C: Future<Output = ()>,
Available on crate feature deploy only.