diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/FakeSubscriberServiceImpl.java b/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/FakeSubscriberServiceImpl.java
index 66ad0d9edad5..56c73d07fe5a 100644
--- a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/FakeSubscriberServiceImpl.java
+++ b/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/FakeSubscriberServiceImpl.java
@@ -264,6 +264,7 @@ public void modifyAckDeadline(
   public void sendError(Throwable error) throws InterruptedException {
     waitForRegistedSubscription();
     synchronized (openedStreams) {
+      waitForOpenedStreams(1);
       Stream stream = openedStreams.get(getAndAdvanceCurrentStream());
       stream.responseObserver.onError(error);
       closeStream(stream);