Skip to content

Instantly share code, notes, and snippets.

@SET001

SET001/rxjs.test.js

Created May 4, 2017 20:52
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save SET001/66af0fceee72288bd5bb7e1b5f35a62c to your computer and use it in GitHub Desktop.
Save SET001/66af0fceee72288bd5bb7e1b5f35a62c to your computer and use it in GitHub Desktop.
Download ZIP
Raw
rxjs.test.js
const dataStream = Rx.Observable.create((observer)=>{
setInterval(()=>{
const value = Math.ceil(Math.random()*100)
observer.next(value)
}, 1000)
})
dataStream.subscribe((o)=>console.log(o))
dataStream
.filter(a=>a<10)
.subscribe(d=>console.log("--->", d))
dataStream
.filter((a)=>a>90)
.subscribe({
next: d=>console.log("===>", d),
error: error=>console.log("!!!!", error)
})
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment