TypeScript example

TypeScript example

by Bhesh Gurung

HTML

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

TypeScript

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

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

subscription.unsubscribe()