We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent bbd501c commit 6af9b99Copy full SHA for 6af9b99
google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/FakeSubscriberServiceImpl.java
@@ -264,6 +264,7 @@ public void modifyAckDeadline(
264
public void sendError(Throwable error) throws InterruptedException {
265
waitForRegistedSubscription();
266
synchronized (openedStreams) {
267
+ waitForOpenedStreams(1);
268
Stream stream = openedStreams.get(getAndAdvanceCurrentStream());
269
stream.responseObserver.onError(error);
270
closeStream(stream);
0 commit comments