We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d325afb commit 4fd6705Copy full SHA for 4fd6705
google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/spi/v1/FakeSubscriberServiceImpl.java
@@ -208,6 +208,7 @@ public void sendStreamingResponse(StreamingPullResponse pullResponse)
208
throws InterruptedException {
209
waitForRegistedSubscription();
210
synchronized (openedStreams) {
211
+ waitForOpenedStreams(1);
212
openedStreams.get(getAndAdvanceCurrentStream()).responseObserver.onNext(pullResponse);
213
}
214
0 commit comments