lens is a vastly over-engineered, intimidating, complex beast (речь про пакет lens, не про идею)

Меня кстати бесит рекомпоуз не только безумным количеством вложенных хоков на выходе но и адом типизации

Во: const request$ = new Subject() const subscription = request$ .startWith(null) .mapTo(params) .map(getUpdates) .mergeMap(Observable.fromPromise) .do(request$) .subscribe((response) => { if (response.ok) { response.result.forEach(emit) } })

Вот такая реализация long polling: const request$ = new Subject() const subscription = request$ .mapTo(params) .map(getUpdates) .subscribe( resPromise => resPromise.then( (response) => { if (response.ok) { response.result.forEach(emit) } request$.next() }, ), ) request$.next() Но это вообще нормально — генерировать событие прямо из подписчика?

https://www.learnrxjs.io/operators/transformation/expand.html

А это валидная конструкция? .catch(Observable.of) .map(error)

в общем, нет, это не то же самое, если catch от промиса, то вернется промис

map же не ошибку мапнет

https://github.com/fluture-js/Fluture/blob/master/README.md#maprej

Хотя mapRej вроде от catch не отличается @ZeroBias ?

мапРеж он на то и мап, что не меняет структуры. Я бы назвал chainRej)

Observable.prototype.mapRej = function (f) { return this.catch(x => Observable.throw(f(x))) } Че-то такое?)

Не так то зря над http://jlmorgan.github.io/node-lodash-fantasy смеетесь

А че такое Kan Extensions?

А mapRej только те которые Future.reject ?

ну я не знаю что там за причина сегфолта

In my opinion lens doesn’t have enough focus

линзы поверхностно изучил и стало скучно, нашел новую либу для изучения - pipes