Function process_yaml_stream

pub async fn process_yaml_stream<R, F, Fut>(
    parser: AsyncStreamingParser<R>,
    callback: F,
) -> Result<()>
where
    R: AsyncBufRead + Unpin,
    F: FnMut(Event) -> Fut,
    Fut: Future<Output = Result<()>>,

Process YAML stream with a callback