trying CycleJS + XStream for the first time

panel.ts

import xs from 'xstream';
import { run } from '@cycle/xstream-run';
import { makeDOMDriver, div } from '@cycle/dom';
// import { Observable } from 'rxjs/Observable';

const
    html = require('./panel.html'),
    css = require('./panel.css');

function main() {
    const subscriptions$ = xs.of([
        { name: 'just testing 1' },
        { name: 'just testing 2' },
        { name: 'just testing 3' },
        { name: 'just testing 4' },
    ]);

    const subscriptionsDom$ = subscriptions$
        .map(subs => xs.from(subs))
        .flatten()
        .map(sub => {
            return div('.section-row', [
                div('.section-cell.section-cell--fixed-2', [
                    'XXX'
                ]),
                div('.section-cell.section-cell--flex.align-center', [
                    'XXX1'
                ]),
                div('.section-cell.section-cell--fixed-1.align-right', [
                    'XXX2'
                ])
            ]);
        })
        .fold((r, t) => r.concat([t]), []);

    const sinks = {
        subscriptionsCount: subscriptions$.map(x => x.length),
        subscriptionsList: subscriptionsDom$
    };

    return sinks;
}

const drivers = {
    subscriptionsCount: makeDOMDriver('#subscriptionsCount'),
    subscriptionsList: makeDOMDriver('#subscriptionsList')
};

run(main, drivers);