---

pongad · web-flow · commit 224ad861ccea · 2016-12-22T14:02:37.000+11:00
yaml --- r: 5325 b: refs/heads/master c: c206efe h: refs/heads/master i: 5323: b5042e7
diff --git a/[refs] b/[refs]
@@ -1,5 +1,5 @@
 ---
-refs/heads/master: 994479fc57933fbf96b2cf24709c29cf3111d430
+refs/heads/master: c206efeb0dcebd87bc712e1a23b53eec3a2ed301
 refs/heads/travis: dae77e558b884bc1b165155482d76c8e40b0fca4
 refs/heads/gh-pages: 229631582f8957646f81e92ae5a326504f48ee5b
 refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444
diff --git a/trunk/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/FakeSubscriberServiceImpl.java b/trunk/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);
