flux to mono converstion using next() method

src/main/java/com/nisum/poc/Webflux/config/WebclientEx.java

@@ -22,8 +22,10 @@ public class WebclientEx {
     public void getAllStudents(){
         log.info("----------------------------------in scheduler method--------------------------------");
         WebClient client = WebClient.create("http://localhost:4042");
-        Flux<Address> studentFlux = client.get().uri("/alladdress").accept(MediaType.TEXT_EVENT_STREAM).retrieve().bodyToFlux(Address.class);
-        studentFlux.filter(a -> a.getCity().equalsIgnoreCase("hyd")).subscribe(a -> System.out.println(a.toString()));
+        Flux<Address> addressFlux = client.get().uri("/alladdress").accept(MediaType.TEXT_EVENT_STREAM).retrieve().bodyToFlux(Address.class);
+        //converting Flux to Mono using next()
+        Mono<Address> addressMono = client.get().uri("/alladdress").accept(MediaType.TEXT_EVENT_STREAM).retrieve().bodyToFlux(Address.class).next();
+        addressFlux.filter(a -> a.getCity().equalsIgnoreCase("hyd")).subscribe(a -> System.out.println(a.toString()));
         //return studentFlux;
     }