Function forward_async_iter

crates/python/src/py_callable.rs:141–165

(
    async_iter: Arc<Py<PyAny>>,
    tx: tokio::sync::mpsc::Sender<FlowResult<Json>>,
)

}

async fn forward_async_iter(
    async_iter: Arc<Py<PyAny>>,
    tx: tokio::sync::mpsc::Sender<FlowResult<Json>>,
) {
    loop {
        let next_value = match next_async_iter_coro(&async_iter) {
            Ok(None) => break,
            Ok(Some(coro)) => await_async_iter_value(coro).await,
            Err(error) => Err(error),
        };

        match next_value {
            Ok(Some(value)) => {
                if tx.send(Ok(value)).await.is_err() {
                    break;
                }
            }
            Ok(None) => break,
            Err(error) => {
                let _ = tx.send(Err(error)).await;
                break;
            }
        }
    }
}

fn stream_from_async_iter(
    async_iter: Py<PyAny>,