Polish "Use Flux.interval in Webflux samples"

Signed-off-by: onobc <[email protected]>

Author: onobc

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

@@ -4,6 +4,7 @@
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+
 import org.springframework.grpc.sample.proto.HelloReply;
 import org.springframework.grpc.sample.proto.HelloRequest;
 import org.springframework.grpc.sample.proto.SimpleGrpc;
@@ -34,12 +35,10 @@ public void sayHello(HelloRequest req, StreamObserver<HelloReply> responseObserv
 	@Override
 	public void streamHello(HelloRequest req, StreamObserver<HelloReply> responseObserver) {
 		log.info("Hello " + req.getName());
-
-		// 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

@@ -4,6 +4,7 @@
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+
 import org.springframework.grpc.sample.proto.HelloReply;
 import org.springframework.grpc.sample.proto.HelloRequest;
 import org.springframework.grpc.sample.proto.SimpleGrpc;
@@ -34,12 +35,10 @@ public void sayHello(HelloRequest req, StreamObserver<HelloReply> responseObserv
 	@Override
 	public void streamHello(HelloRequest req, StreamObserver<HelloReply> responseObserver) {
 		log.info("Hello " + req.getName());
-
-		// 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);
 	}
 
-}
+}