ump 0.13.0

Micro message passing library for threads/tasks communication.
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
47
48
49
50
51
52
53

use ump::{channel, Error};

#[test]
fn sync_weak_should_not_count() {
  let (server, client) = channel::<String, String, ()>();

  let _weak_client = client.weak();

  // nuke the only (strong) client
  drop(client);

  let Err(Error::ClientsDisappeared) = server.wait() else {
    panic!("Unexpected error");
  };
}

#[test]
fn async_weak_should_not_count() {
  let tokrt = tokio::runtime::Runtime::new().unwrap();

  let (server, client) = channel::<String, String, ()>();

  let _weak_client = client.weak();

  // nuke the only client
  drop(client);

  tokrt.block_on(async {
    let Err(Error::ClientsDisappeared) = server.async_wait().await else {
      panic!("Unexpected error");
    };
  });
}

#[test]
fn upgraded_should_count() {
  let (server, client) = channel::<String, String, ()>();

  let weak_client = client.weak();

  let Some(_client2) = weak_client.upgrade() else {
    panic!("Unable to upgrade weak_client");
  };

  // nuke original client
  drop(client);

  let Ok(None) = server.try_pop() else {
    panic!("Unexpected error");
  };
}

// vim: set ft=rust et sw=2 ts=2 sts=2 cinoptions=2 tw=79 :