b754d51e8e
* chore(package): update jasmine to version 3.0.0 Closes #4547 * Fixes failing tests for jasmine 3.0 Starting 3.0, done(something) will fail * Update tests so they dont leverage var, but let and const With jasmine 3.0, the randomization engine was making the test fails because of the scope of `var` * Remove randomizer * Use same adapter for PG tests, drop table to ensure the tests dont side effect
44 lines
1.5 KiB
JavaScript
44 lines
1.5 KiB
JavaScript
const EventEmitterPubSub = require('../src/Adapters/PubSub/EventEmitterPubSub').EventEmitterPubSub;
|
|
|
|
describe('EventEmitterPubSub', function() {
|
|
it('can publish and subscribe', function() {
|
|
const publisher = EventEmitterPubSub.createPublisher();
|
|
const subscriber = EventEmitterPubSub.createSubscriber();
|
|
subscriber.subscribe('testChannel');
|
|
// Register mock checked for subscriber
|
|
let isChecked = false;
|
|
subscriber.on('message', function(channel, message) {
|
|
isChecked = true;
|
|
expect(channel).toBe('testChannel');
|
|
expect(message).toBe('testMessage');
|
|
});
|
|
|
|
publisher.publish('testChannel', 'testMessage');
|
|
// Make sure the callback is checked
|
|
expect(isChecked).toBe(true);
|
|
});
|
|
|
|
it('can unsubscribe', function() {
|
|
const publisher = EventEmitterPubSub.createPublisher();
|
|
const subscriber = EventEmitterPubSub.createSubscriber();
|
|
subscriber.subscribe('testChannel');
|
|
subscriber.unsubscribe('testChannel');
|
|
// Register mock checked for subscriber
|
|
let isCalled = false;
|
|
subscriber.on('message', function() {
|
|
isCalled = true;
|
|
});
|
|
|
|
publisher.publish('testChannel', 'testMessage');
|
|
// Make sure the callback is not called
|
|
expect(isCalled).toBe(false);
|
|
});
|
|
|
|
it('can unsubscribe not subscribing channel', function() {
|
|
const subscriber = EventEmitterPubSub.createSubscriber();
|
|
|
|
// Make sure subscriber does not throw exception
|
|
subscriber.unsubscribe('testChannel');
|
|
});
|
|
});
|