Есть ли способ работать мимо потока функционально? - PullRequest
2 голосов
/ 28 апреля 2019

В методе мой код обращается к базе данных и возвращает поток данных из источника.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();
}

Это проблематично, когда я хочу объединить все в большую реализацию.Есть ли здесь что-то, чего мне не хватает, чтобы я мог достичь чего-то подобного?

...