perspective 2.0.0

A data visualization and analytics component, especially well-suited for large and/or streaming datasets.
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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91

////////////////////////////////////////////////////////////////////////////////
//
// Copyright (c) 2018, the Perspective Authors.
//
// This file is part of the Perspective library, distributed under the terms
// of the Apache License 2.0.  The full license can be found in the LICENSE
// file.

use std::cell::RefCell;
use std::rc::Rc;

use wasm_bindgen_test::*;

use super::super::pubsub::*;

#[wasm_bindgen_test]
pub async fn test_pub_sub() {
    let pubsub: PubSub<u32> = PubSub::default();
    let called: Rc<RefCell<Option<u32>>> = Rc::new(RefCell::new(None));
    let callback = {
        let called = called.clone();
        move |x| {
            *called.borrow_mut() = Some(x);
        }
    };

    let sub = pubsub.add_listener(callback);
    pubsub.emit_all(1);
    assert_eq!(*called.borrow(), Some(1));
    drop(sub);
}

#[wasm_bindgen_test]
pub async fn test_pub_sub_multiple() {
    let pubsub: PubSub<u32> = PubSub::default();
    let called1: Rc<RefCell<Option<u32>>> = Rc::new(RefCell::new(None));
    let called2: Rc<RefCell<Option<u32>>> = Rc::new(RefCell::new(None));
    let callback1 = {
        let called = called1.clone();
        move |x| {
            *called.borrow_mut() = Some(x);
        }
    };

    let callback2 = {
        let called = called2.clone();
        move |x| {
            *called.borrow_mut() = Some(x);
        }
    };

    // Must be in scope or subscriptions will drop immediately!
    let sub1 = pubsub.add_listener(callback1);
    let sub2 = pubsub.add_listener(callback2);

    pubsub.emit_all(1);
    assert_eq!(*called1.borrow(), Some(1));
    assert_eq!(*called2.borrow(), Some(1));

    drop(sub1);
    drop(sub2);
}

#[wasm_bindgen_test]
pub async fn test_pub_sub_multiple_drop_first() {
    let pubsub: PubSub<u32> = PubSub::default();
    let called1: Rc<RefCell<Option<u32>>> = Rc::new(RefCell::new(None));
    let called2: Rc<RefCell<Option<u32>>> = Rc::new(RefCell::new(None));
    let callback1 = {
        let called = called1.clone();
        move |x| {
            *called.borrow_mut() = Some(x);
        }
    };

    let callback2 = {
        let called = called2.clone();
        move |x| {
            *called.borrow_mut() = Some(x);
        }
    };

    let _ = pubsub.add_listener(callback1);
    let sub = pubsub.add_listener(callback2);

    pubsub.emit_all(1);
    assert_eq!(*called1.borrow(), None);
    assert_eq!(*called2.borrow(), Some(1));

    drop(sub);
}