Хочу сделать агрегирующий метод, который дёргает другие микросервисы по ресту.

✙Vlad
Сделай новый энтити и в сервисе собери, или mapstr...

Сделай новый энтити и в сервисе собери, или mapstruct

0

28.05.2022

не Миша, а проапрволпоав888 天使 Автор вопроса

Так там моно, параметризованные разными классами. Или я чего-то не понимаю? Как примерно должен выглядеть этот класс?

0

28.05.2022

А в чем их отличие?

0

28.05.2022

Andrei Serov
Попробуй zip

Если это разные урлы, то вы можете параметризовать метод

0

28.05.2022

не Миша, а проапрволпоав888 天使 Автор вопроса

Норм. Тогда метод контроллера возвращает Mono<Tuple2<DtoA, DtoB>> и всё работает, но ответ выглядит как-то так: { "t1": { ... }, "t2": { ... } } Это мне какой-то свой сериализатор писать, чтобы JSON проперти переименовать из t1 в DtoA, например?

0

28.05.2022

не Миша, а проапрволпоав888 天使
Норм. Тогда метод контроллера возвращает Mono<Tupl...

Да, потом, flatMap и мапь в нужный формат

0

28.05.2022

не Миша, а проапрволпоав888 天使 Автор вопроса

Dima
Если это разные урлы, то вы можете параметризовать...

Мне именно нужно реактивно обращаться к другим микросервисам, агрегировать ответы от них в одном методе и возвращать всё это добро

0

28.05.2022

не Миша, а проапрволпоав888 天使
Так там моно, параметризованные разными классами. ...

Вытянр дто и собери в один объект

0

28.05.2022

не Миша, а проапрволпоав888 天使
Мне именно нужно реактивно обращаться к другим мик...

Причем тут реактивность? Дождись оба ответа и собирай, зачем маппить асинхронно?

0

28.05.2022

не Миша, а проапрволпоав888 天使
Норм. Тогда метод контроллера возвращает Mono<Tupl...

Не надо есть свойство @JsonProperty

0

28.05.2022

Dima
Не надо есть свойство @JsonProperty

А как это повешать на библиотечную структуру Tuple?

0

28.05.2022

не Миша, а проапрволпоав888 天使 Автор вопроса

Так норм? InfoResponse - моя ДТОшка, в которую вложены остальные return Mono.zip(medicalServiceMono, qrCodeServiceMono).flatMap(data -> { VaccinationDto vaccinationDto = data.getT1(); QrCodeDto qrCodeDto = data.getT2(); return Mono.just(new InfoResponse(vaccinationDto, qrCodeDto)); }); Мой метод контроллера возвращает соответственно Mono<InfoResponse>

0

28.05.2022

Нужно делать запрос не блокируя тред.

0

28.05.2022

✙Vlad
Причем тут реактивность? Дождись оба ответа и соби...

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

0

28.05.2022

Andrei Serov
Может быть куча ведь запросов в другие сервисы. И ...

А во flatmap, он будет ждать данные от несколько сервисов?

0

28.05.2022

не Миша, а проапрволпоав888 天使
Так норм? InfoResponse - моя ДТОшка, в которую вло...

Да, Только наверн вызовы нужно внутри зипа.

0

28.05.2022

Dima
А во flatmap, он будет ждать данные от несколько с...

По идее должен, ведь стрим идёт по всем элементам.

0

28.05.2022

Dima
А во flatmap, он будет ждать данные от несколько с...

Да и в прям zip будет ждать когда все испустят элементы и объеденит их

0

28.05.2022

✙Vlad
Причем тут реактивность? Дождись оба ответа и соби...

Я так думаю, чтобы не занимать потоки вызовов, ведь при реактивности, свободные ресурсы распределяются, а не ждут полного выполнения. Но само собой придётся тогда работать через subscribe

0

28.05.2022

Andrei Serov
Нужно делать запрос не блокируя тред.

Я не говорил блокировать тред, ты в любом случае не получишь объект пока оба запроса не выполнятся

0

28.05.2022

Andrei Serov · Accepted Answer