Я пытаюсь написать интеграционный тест для одного из API моего приложения, основанного на Spring Webflux. Я интегрировал внешнюю библиотеку, разработанную моей организацией и обеспечивающую поддержку аутентификации с использованием токенов JWT....
Мне нужно убедиться, что все операции со всеми элементами пользователя завершены, прежде чем что-то делать с записью пользователя. Перед тем как продолжить, сокращение ожидает всех элементов из FlatMap? Если нет, то как я могу это сделать?...
Мне нужно объединить большие потоки данных, доступные через Flux, каждый из которых содержит метку времени и значение. Если временные метки совпадают, то значения необходимо просуммировать. Данные в потоке сортируются по метке времени в порядке...