iansinnott

import ms from 'ms';
import Rx from 'rxjs/Rx';

const clicks$ = Rx.Observable.fromEvent(document.body, 'click');

const createActionStream = () => Rx.Observable.merge(
  Rx.Observable.of({ type: 'warning' }).delay(ms('14m')),
  Rx.Observable.of({ type: 'logOut' }).delay(ms('15m'))
);