pub async fn multi_location_test<'a, T, C, O: Ordering, R: Retries>(
thunk: impl FnOnce(&FlowBuilder<'a>, &Process<'a, ()>) -> Stream<T, Process<'a>, Unbounded, O, R>,
check: impl FnOnce(Pin<Box<dyn Stream<Item = T>>>) -> C,
)
Available on crate feature
deploy
only.Expand description
Sets up a test with multiple processes / clusters declared in the test logic (thunk
). The test logic must return
a single streaming output, which can then be read in check
(an async closure) to perform assertions.
Each declared process is deployed as a single local process, and each cluster is deployed as four local processes.