Неблокирующий API для отдыха с использованием Spring Webflux ⇐ JAVA

[Anonymous]

У меня есть требование сделать панель управления неблокирующей rest API со следующей информацией:

• Профиль клиента – полученный от стороннего API
• Учетные записи клиентов – получены из другого стороннего API.
• Список преимуществ клиентов – получены из базы данных.

Структура ответа примерно такая:

Код: Выделить всё

 {
"profile": {
"id": "123",
"name": "John Doe",
"email": "john.doe@example.com"
},
"accounts": {
"accountNumber": "ACC-456",
"balance": 1000.0
},
"beneficiaries": [
{
"name": "John Doe Sister",
"address": "XYX"
}
]
}

выше, если какой-либо ответ приходит первым, наш API должен возвращать тот же самый объект ответа и обновлять тот же объект ответа данными при получении, например, если API учетных записей дает данные первым, тогда мы не должны ждать профиля и выгоды результат такой же, как поток данных, когда бы он ни пришел, наш API отправляет то же самое.
Пробовал приведенный ниже код, но требование не выполняется.

Код: Выделить всё

public Flux getCustomerDashboard(String customerId) {

// Create a Mono for profile and beneficiaries
Mono profileMono = Mono.just(createDummyProfile());
Mono beneficiariesMono = Mono.just(createBene());
// Create a Flux to emit the initial data
return Mono.zip(profileMono, beneficiariesMono)
.flatMapMany(tuple -> {
// Create the dashboardDTO and set profile and beneficiaries
CustomerDashboardDTO dashboardDTO = new CustomerDashboardDTO();
dashboardDTO.setProfile(tuple.getT1());
dashboardDTO.setBeneficiaries(tuple.getT2());

// Emit the initial DTO immediately
Flux initialEmission = Flux.just(dashboardDTO);

// After a delay, fetch accounts and update the DTO
Mono updatedEmission = Mono.delay(Duration.ofSeconds(10))
.flatMap(delay -> {
CustomerAccount account = createDummyAccounts(); // Fetch accounts
dashboardDTO.setAccounts(account); // Update DTO with accounts
return Mono.just(dashboardDTO); // Emit the updated DTO
});

// Combine initial and updated emissions
return initialEmission.concatWith(updatedEmission);
})
.doOnNext(dto -> System.out.println("Emitting DTO: " + dto)); // Log emission
}

Этот код возвращает ответ, как показано ниже, и тоже после задержки в 10 секунд.

Код: Выделить всё

   {
"profile": {
"id": "123",
"name": "John Doe",
"email": "john.doe@example.com"
},
"accounts": null,
"beneficiaries": [
{
"name": "John Doe sister",
"address": "xyx"
}
]
}
{
"profile": {
"id": "123",
"name": "John Doe",
"email": "john.doe@example.com"
},
"accounts": {
"accountNumber": "ACC-456",
"balance": 1000.0
},
"beneficiaries": [
{
"name": "John Doe Sister",
"address": "XYX"
}
]
}

Пожалуйста, помогите решить проблему за последние 2–3 дня. Я также новичок в реактивном программировании.

Подробнее здесь: https://stackoverflow.com/questions/790 ... ng-webflux