RxJS 5 Playground

by Bhesh Gurung

HTML

<script src="https://unpkg.com/@reactivex/[email protected]/dist/global/Rx.js"></script>

JavaScript

let source = Rx.Observable.create((observer: NextObserver<any>) => {
	observer.next('Hello')
  observer.complete()
})

let subscription = source.subscribe(message => {
	console.log(message)
})

subscription.unsubscribe()