Как преобразовать синхронный вызов функции в наблюдаемую?

Question

Существует ли стандартный способ или создатель в RxJS 6 lib, который преобразует вызов функции в наблюдаемую подобную этому?

const liftFun = fun => {
    try {
        return of(fun())
    } catch (err) {
        return throwError(err)
    }
}

Answer 1

Наблюдаемым

 const liftFun=fun=>new Observable(obs=>{
        try {
            return obs.next(fun)
        } catch (err) {
            return obs.error(err)
        }
    })

Или вы хотите преобразовать в операторную функцию для использования в pipe цепочке

const liftFun = fun => mergeMap(fun=>({
    try {
        return of(fun())
    } catch (err) {
        return throwError(err)
    }
})