Skip to content

Commit a071dbf

Browse files
committed
Configure integration test to go quicker
Signed-off-by: Dave Syer <[email protected]>
1 parent 3176c7b commit a071dbf

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

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

+5-1
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22

33
import org.apache.commons.logging.Log;
44
import org.apache.commons.logging.LogFactory;
5+
import org.springframework.beans.factory.annotation.Value;
56
import org.springframework.grpc.sample.proto.HelloReply;
67
import org.springframework.grpc.sample.proto.HelloRequest;
78
import org.springframework.grpc.sample.proto.SimpleGrpc;
@@ -14,6 +15,9 @@ public class GrpcServerService extends SimpleGrpc.SimpleImplBase {
1415

1516
private static Log log = LogFactory.getLog(GrpcServerService.class);
1617

18+
@Value("${stream.count:10}")
19+
int COUNT = 0;
20+
1721
@Override
1822
public void sayHello(HelloRequest req, StreamObserver<HelloReply> responseObserver) {
1923
log.info("Hello " + req.getName());
@@ -26,7 +30,7 @@ public void sayHello(HelloRequest req, StreamObserver<HelloReply> responseObserv
2630
public void streamHello(HelloRequest req, StreamObserver<HelloReply> responseObserver) {
2731
log.info("Hello " + req.getName());
2832
int count = 0;
29-
while (count < 10) {
33+
while (count < COUNT) {
3034
HelloReply reply = HelloReply.newBuilder().setMessage("Hello(" + count + ") ==> " + req.getName()).build();
3135
responseObserver.onNext(reply);
3236
count++;

samples/grpc-tomcat/src/test/java/org/springframework/grpc/sample/GrpcServerApplicationTests.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
import org.springframework.test.annotation.DirtiesContext;
1717

1818
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
19-
properties = "spring.grpc.client.default-channel.address=0.0.0.0:${local.server.port}")
19+
properties = { "spring.grpc.client.default-channel.address=0.0.0.0:${local.server.port}", "stream.count=2" })
2020
@DirtiesContext
2121
public class GrpcServerApplicationTests {
2222

0 commit comments

Comments
 (0)