Skip to content

Instantly share code, notes, and snippets.

View iansinnott's full-sized avatar

Ian Sinnott iansinnott

View GitHub Profile
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'))
);