cyboard/dist/mergeWidgetBackends.test.js

'use strict';

var _Observable = require('rxjs/Observable');

var _Subject = require('rxjs/Subject');

var _mergeWidgetBackends = require('./mergeWidgetBackends');

test('returns observable', function () {
    var backends = (0, _mergeWidgetBackends.mergeWidgetBackends)({});
    expect(backends).toBeInstanceOf(_Observable.Observable);
});

test('merges data from all backends', function () {
    var backendA = new _Subject.Subject();
    var backendB = new _Subject.Subject();
    var subscriber = jest.fn();

    var backends = (0, _mergeWidgetBackends.mergeWidgetBackends)({
        board: {
            widgets: [{ backend: backendA }, { backend: backendB }]
        }
    });

    backends.subscribe(subscriber);

    backendA.next(1);
    backendB.next(2);

    expect(subscriber).toHaveBeenCalledTimes(2);
});

test('works with boards without widgets', function () {
    var backends = (0, _mergeWidgetBackends.mergeWidgetBackends)({
        board: {}
    });
    expect(backends).toBeInstanceOf(_Observable.Observable);
});