Create an Rx.Observable out of setTimeout/setInterval

fromTimeout.js

import { Observable } from 'rxjs'

const fromTimeout = ts => Observable.create(observer => {
    const handle = setTimeout(() => { 
        observer.next()
        observer.complete()
    }, ts)

    return function dispose() {
        observer.onComplete()
        clearTimeout(handle)
    }
})

const wait1 = fromTimeout(1000)
const wait2 = fromTimeout(2000)

const waiting1 = wait1.subscribe(() => console.log(’This will never be printed’))
const waiting2 = wait2.subscribe(() => console.log(’Time has passed’))

waiting1.unsubscribe() // will never fire