diff --git a/samples/grpc-server-netty-shaded/src/main/java/com/example/demo/GrpcServerService.java b/samples/grpc-server-netty-shaded/src/main/java/com/example/demo/GrpcServerService.java index c2f01e1..5b9ade0 100644 --- a/samples/grpc-server-netty-shaded/src/main/java/com/example/demo/GrpcServerService.java +++ b/samples/grpc-server-netty-shaded/src/main/java/com/example/demo/GrpcServerService.java @@ -2,7 +2,6 @@ package com.example.demo; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import com.example.demo.proto.HelloReply; @@ -25,7 +24,6 @@ public class GrpcServerService extends SimpleGrpc.SimpleImplBase { } @Override - @Async public void streamHello(HelloRequest req, StreamObserver responseObserver) { log.info("Hello " + req.getName()); int count = 0; diff --git a/samples/grpc-server/src/main/java/org/springframework/grpc/sample/GrpcServerService.java b/samples/grpc-server/src/main/java/org/springframework/grpc/sample/GrpcServerService.java index a5f0525..ed22c56 100644 --- a/samples/grpc-server/src/main/java/org/springframework/grpc/sample/GrpcServerService.java +++ b/samples/grpc-server/src/main/java/org/springframework/grpc/sample/GrpcServerService.java @@ -5,7 +5,6 @@ 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; -import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import io.grpc.stub.StreamObserver; @@ -30,7 +29,6 @@ public class GrpcServerService extends SimpleGrpc.SimpleImplBase { } @Override - @Async public void streamHello(HelloRequest req, StreamObserver responseObserver) { log.info("Hello " + req.getName()); int count = 0; diff --git a/samples/grpc-tomcat/src/main/java/org/springframework/grpc/sample/GrpcServerService.java b/samples/grpc-tomcat/src/main/java/org/springframework/grpc/sample/GrpcServerService.java index fdf0ba7..c7ce150 100644 --- a/samples/grpc-tomcat/src/main/java/org/springframework/grpc/sample/GrpcServerService.java +++ b/samples/grpc-tomcat/src/main/java/org/springframework/grpc/sample/GrpcServerService.java @@ -5,7 +5,6 @@ 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; -import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import io.grpc.stub.StreamObserver; @@ -24,7 +23,6 @@ public class GrpcServerService extends SimpleGrpc.SimpleImplBase { } @Override - @Async public void streamHello(HelloRequest req, StreamObserver responseObserver) { log.info("Hello " + req.getName()); int count = 0;