60c80611ea
Alias would remove unnecessary repetitions and less relative paths make changes easier when moving around files. This commit cleans also up some relative paths ('../../../') by using the alias and orders imports. It updates both path alias in tsconfig and module alias in Vue CLI's bundler (vuejs/vue-cli#2398).
85 lines
3.0 KiB
TypeScript
85 lines
3.0 KiB
TypeScript
import 'mocha';
|
|
import { expect } from 'chai';
|
|
import { EventHandler, IEventSource, IEventSubscription } from '@/infrastructure/Events/IEventSource';
|
|
import { EventSource } from '@/infrastructure/Events/EventSource';
|
|
|
|
describe('EventSource', () => {
|
|
class ObserverMock {
|
|
public readonly onReceiveCalls = new Array<number>();
|
|
public readonly callbacks = new Array<EventHandler<number>>();
|
|
public readonly subscription: IEventSubscription;
|
|
constructor(subject: IEventSource<number>) {
|
|
this.callbacks.push((arg) => this.onReceiveCalls.push(arg));
|
|
this.subscription = subject.on((arg) => this.callbacks.forEach((action) => action(arg)));
|
|
}
|
|
}
|
|
let sut: EventSource<number>;
|
|
beforeEach(() => sut = new EventSource());
|
|
describe('single observer', () => {
|
|
// arrange
|
|
let observer: ObserverMock;
|
|
beforeEach(() => {
|
|
observer = new ObserverMock(sut);
|
|
});
|
|
it('notify() executes the callback', () => {
|
|
// act
|
|
sut.notify(5);
|
|
// assert
|
|
expect(observer.onReceiveCalls).to.have.length(1);
|
|
});
|
|
it('notify() executes the callback with the payload', () => {
|
|
const expected = 5;
|
|
// act
|
|
sut.notify(expected);
|
|
// assert
|
|
expect(observer.onReceiveCalls).to.deep.equal([expected]);
|
|
});
|
|
it('notify() does not call callback when unsubscribed', () => {
|
|
// act
|
|
observer.subscription.unsubscribe();
|
|
sut.notify(5);
|
|
// assert
|
|
expect(observer.onReceiveCalls).to.have.lengthOf(0);
|
|
});
|
|
});
|
|
describe('multiple observers', () => {
|
|
// arrange
|
|
let observers: ObserverMock[];
|
|
beforeEach(() => {
|
|
observers = [
|
|
new ObserverMock(sut), new ObserverMock(sut),
|
|
new ObserverMock(sut), new ObserverMock(sut),
|
|
];
|
|
});
|
|
it('notify() should execute all callbacks', () => {
|
|
// act
|
|
sut.notify(5);
|
|
// assert
|
|
observers.forEach((observer) => {
|
|
expect(observer.onReceiveCalls).to.have.length(1);
|
|
});
|
|
});
|
|
it('notify() should execute all callbacks with payload', () => {
|
|
const expected = 5;
|
|
// act
|
|
sut.notify(expected);
|
|
// assert
|
|
observers.forEach((observer) => {
|
|
expect(observer.onReceiveCalls).to.deep.equal([expected]);
|
|
});
|
|
});
|
|
it('notify() executes in FIFO order', () => {
|
|
// arrange
|
|
const expectedSequence = [0, 1, 2, 3];
|
|
const actualSequence = new Array<number>();
|
|
for (let i = 0; i < observers.length; i++) {
|
|
observers[i].callbacks.push(() => actualSequence.push(i));
|
|
}
|
|
// act
|
|
sut.notify(5);
|
|
// assert
|
|
expect(actualSequence).to.deep.equal(expectedSequence);
|
|
});
|
|
});
|
|
});
|