Function stream_transform_test 

pub async fn stream_transform_test<'a, T, C, O: Ordering, R: Retries>(
    thunk: impl FnOnce(&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.

Sets up a test declared in thunk that executes on a single Process, returning a streaming output that can be read in check (an async closure) to perform assertions.