kosich

const { rxObserver, palette } = require('api/v0.3');
const { merge, timer, Subject, from, empty } = require('rxjs');
const { filter, startWith, bufferToggle, take, flatMap, zip, distinctUntilChanged, share, skip, map, windowToggle } = require('rxjs/operators');

// stream for coloring
const palette$ = from(palette);

const source$ = timer(0, 10).pipe(
    take(10),
    // get color for each item

kosich

const { rxObserver, palette } = require('api/v0.3');
const { timer, Subject, from, EMPTY } = require('rxjs');
const { switchMap, take, flatMap, zip, startWith, distinctUntilChanged, map, skip } = require('rxjs/operators');

// stream for coloring
const palette$ = from(palette);

const source$ = timer(0, 10).pipe(
    take(10),
    // get color for each item

kosich

const { rxObserver, palette } = require('api/v0.3');
const { timer, Subject, from } = require('rxjs');
const { windowToggle, startWith, distinctUntilChanged, flatMap, take, zip, filter, skip, map } = require('rxjs/operators');

// stream for coloring
const palette$ = from(palette);

const source$ = timer(0, 10).pipe(
    take(10),
    // get color for each item

kosich

const { rxObserver } = require('api/v0.3');
const { timer, Subject } = require('rxjs');
const { tap, take, takeUntil, map } = require('rxjs/operators');

const userClick = new Subject();
let counter = 5;
let tick = 10;

    timer(0, tick)
      .pipe(

kosich

const { rxObserver } = require('api/v0.3');
const { of, timer, fromEvent, merge, empty, interval, Subject, forkJoin }  = require('rxjs');
const { startWith, switchMap, distinctUntilChanged, map, mapTo, take, tap, concatMap, ignoreElements, multicast, shareReplay }  = require('rxjs/operators');

const mouse$ = new Subject();

const TIMEOUT = 50;

const notifications$ = new Subject();

kosich

const { rxObserver } = require('api/v0.3');
const { timer } = require('rxjs');
const { map, take } = require('rxjs/operators');

timer(0, 100)
  .pipe(
    take(5),
    map(()=>Date.now())
  )
  .subscribe(rxObserver());

kosich

const { rxObserver } = require('api/v0.3');
const { Observable } = require('rxjs/Rx');
const { timer } = require('rxjs');

const autoSave$ = Observable
  .timer(0, 17)
  .map(v => v%2 == 1)
  .takeUntil(timer(100))
  .share();

kosich

const { rxObserver } = require('api/v0.3');
const { Observable } = require('rxjs/Rx');
const { timer } = require('rxjs');

const autoSave$ = Observable
  .timer(0, 17)
  .map(v => v%2 == 1)
  .takeUntil(timer(100))
  .share();

kosich

const { rxObserver } = require('api/v0.3');
const { timer, throwError, of } = require('rxjs');
const { catchError, switchMap } = require('rxjs/operators');

const error$ = timer(5).pipe(
    switchMap(() => throwError('X'))
  );

error$.subscribe(rxObserver('Error'));

kosich

const { rxObserver } = require('api/v0.3');
const { timer, throwError } = require('rxjs');
const { mapTo, tap, catchError, switchMap } = require('rxjs/operators');

const error$ = timer(10).pipe(
    switchMap(() => throwError('X'))
  );

const omittedCatch$ = error$
  .pipe(