В методе мой код обращается к базе данных и возвращает поток данных из источника.Flux - это поток, похожий на API Java Stream.Запрос может или не может вернуть любые объекты, так как они могут не соответствовать предикату.Каков функциональный способ обработки этого, чтобы исключить исключение нулевого указателя?
Я работал над созданием ссылочной переменной, которая будет удерживать полуобработанный поток, и в зависимости от того, есть ли какие-либо элементы илинет, продолжайте обработку.
Flux<SomeObject> objects = dbConn.getObjects(QUERY);
Optional<SomeObject> test = objects.toStream().findFirst();
if(test.is.not.empty){
objects.do_rest_of_processing();
}
Это проблематично, когда я хочу объединить все в большую реализацию.Есть ли здесь что-то, чего мне не хватает, чтобы я мог достичь чего-то подобного?