alef 0.115.9

Opinionated polyglot binding generator for Rust libraries
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

let inner = self.inner.clone();
    {{ bindings_block }}let (tx, rx) = tokio::sync::mpsc::channel(32);
    pyo3_async_runtimes::tokio::get_runtime().spawn(async move {
        match {{ core_call }}.await {
            Err(e) => {
                let _ = tx.send(Err(e)).await;
            }
            Ok(mut stream) => {
                loop {
                    tokio::select! {
                        _ = tx.closed() => break,
                        chunk = futures::StreamExt::next(&mut stream) => match chunk {
                            Some(chunk) => {
                                if tx.send(chunk).await.is_err() {
                                    break;
                                }
                            }
                            None => break,
                        },
                    }
                }
                drop(stream);
            }
        }
    });
    let iter = {{ iter_name }} {
        receiver: Arc::new(tokio::sync::Mutex::new(rx)),
    };
    Ok(Bound::new(py, iter)?.into_any())