https://clojuredocs.org/clojure.core/-%3E

https://clojuredocs.org/clojure.core/-%3E%3E

наверное самые часто используемые

из либ тоже найду, момент

традиционный routing API для http https://github.com/weavejester/compojure

вот еще, но это плохой пример :) концептуально

http://sqlkorma.com/

http://squeryl.org/index.html

А почему не верить? не точные определения?

со стороны js точные

со стороны ТК нет

макросы как-то не очень зависят от фп/ооп. вообще они везде кроме лиспов неуместны, да и то не уверен, что практикующие на кложе пишут макросы

пишу

пишу

например в какой ситуации?

когда бойлерплейта много. Там не всегда подходят функции. В re-frame есть макрос (reg-sub :key (fn [db _] (:key db)) для субскрайберов, и вот часто (очень часто) приходилось писать такие сабсы, где ключ и путь совпадали. Ну я и писал макрос (reg-key-sub :key)

define-ы часто пишутся разными создателями либ

сам использую plumbing, он дает несколько полезных макросов типа letk и fn->

define-ы часто пишутся разными создателями либ

конструкция объявляющая функцию?

не только функцию (ну хотя функцию она тоже создает, но вообще создает глобальный роут)

/stat@combot

combot.org/chat/-1001071213089

А как бот Flood ratio рассчитывает?)

уже кидали вроде сюда

ща найду

чет не нашел)

Ну ладно, ни чего страшного) мне просто казалось, что такая вещь трудноизмерима т.к. субъективна.

Привет, как в rx называется map в который мы могли бы что то вернуть при этом чтобы следующий оператор проигнорировал в параметрах то что мы вернули, а получил предудущий

do ?

черт как же дебильно выразился action$ .ofType(SOME_TYPE) .someMap(params => {type: "bla_bla"}) . flatMap(params => ) В общем что бы someMap вернуло что то но при этом в flatMap мы получили params основные

неет речь идет о redux-observable , мне нужно промежуточно вернуть экшн но при этом сохранить парамтеры в следующем flatMap

Основные?

?

Кароче как do только при этом чтобы вернуть можно было что то

но проигнорировать это далее

черт такое вообще возмонжо?

только если конкат какой нибудль

Не понимаю)

мне кароче хочется разнести логику с токеном и если что задиспатчить что он истек

но при этом далее как бы подождать его апдейта

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

chain это flatMap

Нукась сейчас гляну chain. а подскажи пожалуйста это вообще по практис наверное маразм сначало проверять токен а потом дожидаться апдейта, по идеи надо наверное вляпаться что он истек а потом как нибудь repet'нуть запрос

Не, чейн это действительно flatMap

redux-observable - это event-driven архитектура, просто диспатчи соответствующие эвенты

А есть ли возможность сначало словить 401 а потом как бы задиспатчить заново евент обновив токен? за этими дейтсвиями у меня просто сам евент уже теряется

repeatWhen я сначлао думал, но видимо тоже нет , потому что rxHttpFetch(request) .retryWhen(err => err /** тут логика какая то но не суть**/ .delay(2000) ) Вот тут у меня повторится ошибка а незапрос

То есть через 2 секунды я получу ту же ошибку но не делая сам запрос

Так мб просто retry

Вобщем вопрос такой как можно восставноить то событие на котором мы словили 401, дождавшись обновления токена

нукась сейчас гляну retry

Вобщем вопрос такой как можно восставноить то событие на котором мы словили 401, дождавшись обновления токена

retryWhen(() => tokenUpdateStream)

Так я и заглушку поэтому тестовую и сделал retryWhen => delay action$ .ofType(HTTP_REQUEST) .map(action => action.payload) .flatMap(({request}) => rxHttpFetch(request) .retryWhen(err =>err.delay(2000) ) ) .mergeMap(() => ...) catch() и я стабильно вместо того чтобы делать запрос rxHttpFetch каждый раз через 2 секунды, просто получаю если скажем перед делеем в do распечатать err просто ошибку и все

но почему запрос не повторяется мне не потнятно

В самом httpFetch там код стандартный export const rxHttpFetch = (rxHttpRequest: HttpRequest): Observable<any> => Observable.from((async (): Promise<HttpFetchResponse> => {

Так стоп

Зачем err.delay(2000)

тебе надо сделать запрос, когда токен обновился

У тебя есть стрим токенов?

Дада, это заглушкеа просто логику проверить вместо апдйета токена

просто подождать две секунды и сделатьзапрос

Ну так err не надо трогать

вместо делей я подставлю уже запрос

() => Observable.delay(2000)

Спасибо, пойду проверю

ERROR: S client not available

Просто err придется потрогать чтобы посмотреть что status === 401

Чисто в стримах конечно фигово управлять потоком с ошибками Error ветки не хватает

() => Observable.delay(2000)

хотя в доке err юзают

?

() => Observable.delay(2000)

Мб так не сработает

Property 'delay' does not exist on type 'typeof Observable'

И да в доках err юзают

Блин тогда придется длинючий конский стрим делать, типа проверяем токен, деламе его апдейт а уже потом запрос

такое не декомпозируется у кого нибудь в проектах на более мелкие?

Уродство? action$ .ofType(HTTP_REQUEST) .combineLatest(Observable.fromPromise(validateToken())) .flatMap(([action, token]) => rxHttpFetch(action.payload.request)) .takeUntil(action$.ofType(CANCEL))

а скинь код rxHttpFetch

https://github.com/radiosilence/redux-rx-http/blob/master/src/utils.ts

Вот тут полглядел

хмм, так он не lazy походу

Т.е?

ну от него отписаться и подписаться заново нельзя

он всегда будет Observable.from(Promise.reject(someError))

На fromPromise тогда переписать

не в этом проблема

мб на create?

https://www.learnrxjs.io/operators/creation/create.html

Все сейчас перепишу я понял

а тогда и на err можно цепляться будет?

наверн

Да так и есть

ну все круто

спасибо!

Теперь пойду заебусь с тестами

Тестировать rx по доке redux-observable немного дебильно, я где то видел по интереснее тесты с TestSheduler

cycle/time