Function stream_fn

pub fn stream_fn<F, Item, Fut>(func: F) -> impl Stream<Item = Item>
where
    F: FnOnce(Yielder<Item>) -> Fut,
    Fut: Future<Output = ()>,

Create a new stream

Example

Let’s yield some lyrics (Song: “Verdächtig” by Systemabsturz):

let stream = asynk_strim::stream_fn(|mut yielder| async move {
   yielder.yield_item("Fahr den Imsi-Catcher hoch").await;
   yielder.yield_item("Mach das Richtmikro an").await;
   yielder.yield_item("Bring Alexa auf den Markt").await;
   yielder.yield_item("Zapf den Netzknoten an").await;
   yielder.yield_item("Fahr den Ü-Wagen vor").await;
   yielder.yield_item("Kauf den Staatstrojaner ein").await;
   yielder.yield_item("Fake die Exit-Nodes bei Tor").await;
   yielder.yield_item("Ihr wollt doch alle sicher sein").await;
});

let mut stream = pin!(stream);
while let Some(item) = stream.next().await {
   println!("{item}");
}