Remove unnecessary null filtering

martin-tarjanyi · May 5, 2018 · 96b3faa · 96b3faa
1 parent 98c6f76
commit 96b3faa
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/src/main/java/com/example/webfluxdemo/controller/PersonController.java b/src/main/java/com/example/webfluxdemo/controller/PersonController.java
@@ -15,7 +15,6 @@
 import reactor.core.publisher.Mono;
 
 import java.time.Duration;
-import java.util.Objects;
 import java.util.Set;
 
 @RestController
@@ -44,7 +43,6 @@ public Flux<Person> getPersonsByStringNumber(@RequestParam Set<String> numbers)
     {
         return Flux.fromIterable(numbers)
                    .flatMap(number -> reactiveRedisTemplate.opsForValue().get(number).doOnNext(log::info))
-                   .filter(Objects::nonNull)
                    .map(Integer::valueOf)
                    .flatMap(id -> mongoRepository.findById(id).doOnNext(person -> log.info(person.toString())))
                    .switchIfEmpty(Mono.error(new IllegalArgumentException("Not found person.")));