Function stream_transform_test

pub async fn stream_transform_test<'a, O: Serialize + DeserializeOwned + 'static, C: Future<Output = ()>, OutOrder>(
    thunk: impl FnOnce(&Process<'a>) -> Stream<O, Process<'a>, Unbounded, OutOrder>,
    check: impl FnOnce(Pin<Box<dyn Stream<Item = O>>>) -> C,
)

Available on crate feature build only.