create - 2

RxJS 5 create

by Echyzen

HTML

<script src="https://npmcdn.com/@reactivex/rxjs@5.0.0-beta.8/dist/global/Rx.umd.js"></script>

JavaScript

const coldPromise$ = new Rx.Observable.create(observer => {
	return new Promise((resolve, reject) => {
  const value = new Date()
  resolve(value)
 }).then(res => {
  observer.next(res)
  observer.complete()
 })
})
coldPromise$.subscribe(console.log)

setTimeout(() => coldPromise$.subscribe(console.log), 1000)