Function forward_stream_to_channel

crates/python/src/py_api/mod.rs:100–109

(
    mut stream: RustJsonStream,
    tx: tokio::sync::mpsc::Sender<FlowResult<serde_json::Value>>,
)

}

pub(crate) async fn forward_stream_to_channel(
    mut stream: RustJsonStream,
    tx: tokio::sync::mpsc::Sender<FlowResult<serde_json::Value>>,
) {
    while let Some(item) = stream.next().await {
        if tx.send(item).await.is_err() {
            break;
        }
    }
}

// ---------------------------------------------------------------------------
// Scope stack creation