Function try_stream_fn

pub fn try_stream_fn<F, Ok, Error, Fut>(
    func: F,
) -> impl Stream<Item = Result<Ok, Error>>
where
    F: FnOnce(TryYielder<Ok, Error>) -> Fut,
    Fut: Future<Output = Result<(), Error>>,

Create a new try stream

Example

Let’s yield some lyrics (Song: “Archbombe” by Systemabsturz):

let stream = asynk_strim::try_stream_fn(|mut yielder| async move {
  yielder.yield_ok("Meine Programme habe ich mal ausgecheckt").await;
  yielder.yield_ok("Dass ich mit Zündern reden kann finde ich suspekt").await;
  yielder.yield_ok("Meine Codezeilen haben anfangs Hippies geschrieben").await;
  yielder.yield_error("Von ihrem Pazifismus ist nicht viel geblieben").await;
  yielder.yield_ok("Ich bin echt nicht glücklich und nicht einverstanden").await;

  Err("Ich als Bombensteuerung soll auf Menschen landen")
});

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