rlbot 0.7.0

Rust bindings for the RLBot framework, allowing you to write bots for Rocket League in Rust.
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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

use std::sync::Arc;

#[derive(Debug, Clone)]
pub struct Sender<T> {
    internal: kanal::Sender<T>,
    waker: Arc<mio::Waker>,
}

impl<T> Sender<T> {
    pub fn send(&self, msg: T) -> Result<(), kanal::SendError> {
        self.internal.send(msg)?;
        self.waker.wake().expect("couldn't wake pkanal waker");
        Ok(())
    }

    pub fn drop_and_wake(self) {
        drop(self.internal);
        self.waker.wake().expect("couldn't wake pkanal waker");
    }
}

#[derive(Debug, Clone)]
pub struct Receiver<T> {
    internal: kanal::Receiver<T>,
}

impl<T> Receiver<T> {
    // pub fn recv(&self) -> Result<T, kanal::ReceiveError> {
    //     self.internal.recv()
    // }
    pub fn try_recv(&self) -> Result<Option<T>, kanal::ReceiveError> {
        self.internal.try_recv()
    }
}

pub fn unbounded<T>(registry: &mio::Registry, token: mio::Token) -> (Sender<T>, Receiver<T>) {
    let (ks, kr) = kanal::unbounded::<T>();
    let waker = mio::Waker::new(registry, token).expect("couldn't create pkanal waker");
    (
        Sender {
            internal: ks,
            waker: Arc::new(waker),
        },
        Receiver { internal: kr },
    )
}