Function stop_at_first_error 

pub fn stop_at_first_error(
    results_stream: impl Stream<Item = DbItem>,
) -> impl Stream<Item = DbItem>

Transforms a stream of database items to stop processing after encountering the first error. The error item itself is still emitted before stopping.