JSFiddle - React, Tailwind, and code Playground

by robwormald

HTML

<script src="https://code.angularjs.org/2.0.0-beta.7/Rx.umd.js"></script>

TypeScript

let {Observable} = Rx;


function waitThenThrow(delay, fakeError){
  return function(observable){
    return observable.delay(5000)
     .flatMap(value => Observable.throw(fakeError))
  }
}

Observable.of('hello')
  .let(waitThenThrow(3000, 'fail!!!'))
  .subscribe(
    v => console.log(v),
    err => console.error(err),
    _ => console.log('done')
  )