kievsash

let Rx = window['rxjs'];
let {from, of, asyncScheduler} = Rx;
let {mergeMap, filter, delay} = Rx.operators;
console.clear();

let notifications = [
  { userId: 1, name: 'A1', delay: 100 }, // should be shown
  { userId: 1, name: 'A2', delay: 1500 }, // shouldn't be shown
  { userId: 1, name: 'A3', delay: 2500 }, // shouldn't be shown
  { userId: 1, name: 'A4', delay: 3500 }, // should be shown

kievsash

//value will be emitted at once — synchronously
of(1).subscribe(console.log)

//value will be emitted at once — synchronously
of(1, queueScheduler).subscribe(console.log)

// value will be emitted in mIcrotask just after current mAcrotask
of(1, asapScheduler).subscribe(console.log)

// value will be emitted in another mAcrotask 

kievsash

let Rx = window['rxjs'];
const {of,
       queueScheduler,
       asapScheduler,
       asyncScheduler,
       animationFrameScheduler
      } = Rx;
const {observeOn, tap} = Rx.operators;
console.clear();

kievsash

let Rx = window['rxjs'];
const {of,
       queueScheduler,
       asapScheduler,
       asyncScheduler,
       animationFrameScheduler
      } = Rx;
const {observeOn, tap} = Rx.operators;
console.clear();

kievsash

This is a my proposal for lightning talk at Reactive Conf 2018. Please ⭐️ if you want to listen to it!

ReactiveConf 2018

Conditional Retry logic in Rx.JS in 5 minutes!

Hello Every-buddy! I am Oleksandr, front-end developer in http://tonicforhealth.com/

In this lightning talk I want to share my experience in using Rx.JS retry operator when you need to customize its behaviour for specific Observable error. it is a shortened version of my speech on JS-FW-days conference in Ukraine.

kievsash

    let usersToDelay = {}

    action$
        .ofType(OPEN_NOTIFICATION)
        .distinctUntilChanged( (prev, next) => {
            let userName = next.userName;
            if (usersToDelay[userName]) {
              return true; // do not emit notification
            }
            setTimeout(() => {delete usersToDelay[userName];}, 3000);