polars-stream 0.53.0

Private crate for the streaming execution engine for the Polars DataFrame library
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

use crate::async_primitives::connector;

pub fn channel<T>() -> (Sender<T>, Receiver<T>) {
    let (tx, rx) = connector::connector();
    (Sender { inner: tx }, Receiver { inner: rx })
}

pub struct Sender<T> {
    inner: connector::Sender<T>,
}

impl<T: Send> Sender<T> {
    pub fn send(mut self, value: T) -> Result<(), connector::SendError<T>> {
        self.inner.try_send(value)
    }
}

pub struct Receiver<T> {
    inner: connector::Receiver<T>,
}

impl<T: Send> Receiver<T> {
    pub async fn recv(mut self) -> Result<T, ()> {
        self.inner.recv().await
    }
}