tentacle 0.7.5

Minimal implementation for a multiplexed p2p network framework.
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

use crate::channel::mpsc;
use futures::executor::block_on;
use futures::stream::StreamExt;

#[test]
fn send_recv() {
    let (tx, rx) = mpsc::channel::<i32>(16);
    tx.try_send(2).unwrap();
    tx.try_quick_send(1).unwrap();
    tx.try_send(3).unwrap();
    tx.try_send(4).unwrap();
    tx.try_quick_send(6).unwrap();
    tx.try_send(5).unwrap();

    drop(tx);
    let v: Vec<_> = block_on(rx.map(|item| item.1).collect());
    assert_eq!(v, vec![1, 6, 2, 3, 4, 5]);
}

#[test]
fn send_recv_unbound() {
    let (tx, rx) = mpsc::unbounded::<i32>();
    tx.unbounded_send(2).unwrap();
    tx.unbounded_quick_send(1).unwrap();
    tx.unbounded_send(3).unwrap();
    tx.unbounded_send(4).unwrap();
    tx.unbounded_quick_send(6).unwrap();
    tx.unbounded_send(5).unwrap();

    drop(tx);
    let v: Vec<_> = block_on(rx.map(|item| item.1).collect());
    assert_eq!(v, vec![1, 6, 2, 3, 4, 5]);
}