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
|
import EventAggregator from '../event-aggregator';
describe("EventAggregator", () => {
class TestSubscriber {
notify(event) {
this.called = true;
this.calledWith = event;
}
}
let subject = null;
beforeEach(() => {
subject = new EventAggregator();
});
describe("#publish", () => {
it ("publishes the event to all interested subscribers", () => {
let subscriber = new TestSubscriber();
let otherSubscriber = new TestSubscriber();
subject.subscribe('LOGGED_IN', subscriber);
subject.subscribe('LOGGED_IN', otherSubscriber);
subject.publish({ event: 'LOGGED_IN', username: 'blah' })
expect(subscriber.called).toBeTruthy();
expect(subscriber.calledWith.username).toEqual('blah');
expect(otherSubscriber.called).toBeTruthy();
expect(otherSubscriber.calledWith.username).toEqual('blah');
});
it ("does not publish events to subscribers interested in other events", function() {
let subscriber = new TestSubscriber();
subject.subscribe('LOGGED_IN', subscriber);
subject.publish({ event: 'LOGGED_OUT' })
expect(subscriber.called).toBeFalsy();
expect(subscriber.calledWith).toBeUndefined();
});
});
describe("#unsubscribe", () => {
it ("unsubscribes a listener", () => {
let subscriber = new TestSubscriber();
let otherSubscriber = new TestSubscriber();
subject.subscribe('LOGGED_IN', subscriber);
subject.subscribe('LOGGED_IN', otherSubscriber);
subject.unsubscribe(subscriber);
subject.publish({ event: 'LOGGED_IN', username: 'blah' })
expect(subscriber.called).toBeFalsy();
expect(subscriber.calledWith).toBeUndefined();
expect(otherSubscriber.called).toBeTruthy();
expect(otherSubscriber.calledWith).toBeTruthy();
});
});
});
|
