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