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, palette } = require('api/v0.3');
const { merge, timer, from } = require('rxjs');
const { map, concatMap, take, zip, ignoreElements, startWith } = require('rxjs/operators');

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

const source$ = merge(
    timer(0, 33),
    timer(5, 17)

kosich

const { rxObserver, palette } = require('api/v0.3');
const { timer, Subject, from, empty } = require('rxjs');
const { takeUntil, take, repeatWhen, filter, zip, map, share } = 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 { 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, palette } = require('api/v0.3');
const { of, timer } = require('rxjs');
const { retry, switchMap, timeout } = require('rxjs/operators');

let index = 0;
const source$ = of(void 0).pipe(
    switchMap(()=>
      // 4 attempts
      timer([20, 20, 20, 5][index++])
    )

kosich

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

const sourceObserver = rxObserver('Source');
const errorsObserver = rxObserver('Errors');
const resultObserver = rxObserver('Result');

timer(10, 10).pipe(
  map(x => {

kosich

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

const source$ = timer(0, 5).pipe(
    take(6)
  );

const result$ = source$.pipe(
    // add your code here...

kosich

const { rxObserver } = require('api/v0.3');
const { Subject, interval, merge } = require('rxjs');
const { timeInterval, filter, distinctUntilChanged, map } = require('rxjs/operators');


const START_EVENT = 'RUN';
const END_EVENT = 'END';
const events$ = new Subject();

const result$ = 

kosich

const { rxObserver } = require('api/v0.3');
const { Subject, interval, merge } = require('rxjs');
const { timeInterval, filter, distinctUntilChanged, map , pairwise } = require('rxjs/operators');


const START_EVENT = 'RUN';
const END_EVENT = 'END';
const events$ = new Subject();

const result$ = 

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