Use Flux.interval in Webflux samples

This commit improves the Webflux samples by leveraging
Flux.interval instead of Thread.sleep.

Signed-off-by: NeatGuyCoding <15627489+NeatGuyCoding@users.noreply.github.com>

Author: NeatGuyCoding

samples/grpc-webflux-secure/src/main/java/org/springframework/grpc/sample/GrpcServerService.java

@@ -1,5 +1,7 @@
 package org.springframework.grpc.sample;
 
+import java.time.Duration;
+
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.springframework.grpc.sample.proto.HelloReply;
@@ -8,6 +10,7 @@
 import org.springframework.stereotype.Service;
 
 import io.grpc.stub.StreamObserver;
+import reactor.core.publisher.Flux;
 
 @Service
 public class GrpcServerService extends SimpleGrpc.SimpleImplBase {
@@ -31,21 +34,12 @@ public void sayHello(HelloRequest req, StreamObserver<HelloReply> responseObserv
 	@Override
 	public void streamHello(HelloRequest req, StreamObserver<HelloReply> responseObserver) {
 		log.info("Hello " + req.getName());
-		int count = 0;
-		while (count < 10) {
-			HelloReply reply = HelloReply.newBuilder().setMessage("Hello(" + count + ") ==> " + req.getName()).build();
-			responseObserver.onNext(reply);
-			count++;
-			try {
-				Thread.sleep(1000L);
-			}
-			catch (InterruptedException e) {
-				Thread.currentThread().interrupt();
-				responseObserver.onError(e);
-				return;
-			}
-		}
-		responseObserver.onCompleted();
+
+		// Use reactive Flux.interval() instead of blocking Thread.sleep()
+		Flux.interval(Duration.ofSeconds(1))
+			.take(10)
+			.map(count -> HelloReply.newBuilder().setMessage("Hello(" + count + ") ==> " + req.getName()).build())
+			.subscribe(responseObserver::onNext, responseObserver::onError, responseObserver::onCompleted);
 	}
 
 }

samples/grpc-webflux/src/main/java/org/springframework/grpc/sample/GrpcServerService.java

@@ -1,5 +1,7 @@
 package org.springframework.grpc.sample;
 
+import java.time.Duration;
+
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.springframework.grpc.sample.proto.HelloReply;
@@ -8,6 +10,7 @@
 import org.springframework.stereotype.Service;
 
 import io.grpc.stub.StreamObserver;
+import reactor.core.publisher.Flux;
 
 @Service
 public class GrpcServerService extends SimpleGrpc.SimpleImplBase {
@@ -31,21 +34,12 @@ public void sayHello(HelloRequest req, StreamObserver<HelloReply> responseObserv
 	@Override
 	public void streamHello(HelloRequest req, StreamObserver<HelloReply> responseObserver) {
 		log.info("Hello " + req.getName());
-		int count = 0;
-		while (count < 10) {
-			HelloReply reply = HelloReply.newBuilder().setMessage("Hello(" + count + ") ==> " + req.getName()).build();
-			responseObserver.onNext(reply);
-			count++;
-			try {
-				Thread.sleep(1000L);
-			}
-			catch (InterruptedException e) {
-				Thread.currentThread().interrupt();
-				responseObserver.onError(e);
-				return;
-			}
-		}
-		responseObserver.onCompleted();
+
+		// Use reactive Flux.interval() instead of blocking Thread.sleep()
+		Flux.interval(Duration.ofSeconds(1))
+			.take(10)
+			.map(count -> HelloReply.newBuilder().setMessage("Hello(" + count + ") ==> " + req.getName()).build())
+			.subscribe(responseObserver::onNext, responseObserver::onError, responseObserver::onCompleted);
 	}
 
 }