Например так

Да))

Вообще если будут сложности пиши в лс, я ещё через мавен не подрубал, только сабмодулем

сейчас бы с фоток копировать

На бинтрей на гитхабе есть ссылка)

@iamthevoid заработало, спасибо

Как вызывать OnError из map?

throw

спс

Добрый день. Трогаю webflux. Пытаюсь сделать что-то типа rate limit'а для запросов, счетчик храню в редисе. Вот код: https://gist.github.com/gusevalexey0/2d74bdafa730f8cbdc72182ca7a3bc59

На контроллере получаю 400: Request body is missing

В случае, если число попыток не истрачено, то все работает нормально. То есть проблема где-то в 6 строке, как я понимаю. Там внутри вызов внешнего API через WebClient

Подскажите, куда копать с проблемой. А то даже не совсем понимаю, как нормально дебажить webflux

причем, в логах никакой информации нет при любом уровне логирования

Ну вообще-то тут по RxJava чатик, а не про реактор.
Но вообще если я твой код правильно понял, то если фильтр фильтранет то будет емпти и вывалится наверх эксепшн и до зипа не дойдет, что не так?

Если есть чатик по реактор, буду благодарен. Пока нашел самое близкое по теме) Да и вообще тут более-менее стандартные концепты я использую.

Когда фильтр фильтрует и остается емпти, все работает как ожидалось. Внезапный 400 возникает, когда фильтр не фильтрует ничего.

Впрочем, я уже догадываюсь, что проблема в том, что я пытаюсь дважды сделать .flatMap() для одного Mono

Сложно сказать, тут проблема бизнесовая. код правильный.
По поводу повторов есть много операторов типо retry, repeatWhen и прочего.

я тоже не нашел русского комьюнити по реактору

хотя кажется довольно популярная штука

можно попробовать заменить 6 строку на что-то типа:
.zipWith(Mono.defer(()->customerDataMono.flatMap(this::computeSuccessData)))
или использовать готовый rate limiter https://resilience4j.readme.io/docs/examples-1#section-decorate-mono-or-flux-with-a-ratelimiter

чтобы дебажить этот код, можно добавлять .log() в цепочку вызовов

Спасибо, не знал про .log(), сильно упрощает жизнь

Я уже вполне капитиально зарефакторил это дело, чтобы чейны выглядели логичнее.

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