From 6af9b99fa77c2522f520a39b3f3d76d3e0c6dd97 Mon Sep 17 00:00:00 2001
From: Michael Darakananda <pongad@google.com>
Date: Thu, 22 Dec 2016 11:56:28 +1100
Subject: [PATCH] deflake SubscriberImplTest, maybe

---
 .../java/com/google/cloud/pubsub/FakeSubscriberServiceImpl.java  | 1 +
 1 file changed, 1 insertion(+)

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);