From fef1a16937ff81ea96e8504b053289d2025d8a21 Mon Sep 17 00:00:00 2001
From: Yoshi Automation Bot <yoshi-automation@google.com>
Date: Fri, 24 Apr 2020 22:16:05 -0700
Subject: [PATCH] fix(generator): delay removing streaming response until used
 (#166)

PiperOrigin-RevId: 308294748

Source-Author: Google APIs <noreply@google.com>
Source-Date: Fri Apr 24 11:44:16 2020 -0700
Source-Repo: googleapis/googleapis
Source-Sha: 28e76243c23cc282efbb288cb558c174e3e5e9ee
Source-Link: https://github.com/googleapis/googleapis/commit/28e76243c23cc282efbb288cb558c174e3e5e9ee
---
 .../com/google/cloud/speech/v1/MockSpeechImpl.java     |  3 ++-
 .../google/cloud/speech/v1p1beta1/MockSpeechImpl.java  |  3 ++-
 synth.metadata                                         | 10 +++++-----
 3 files changed, 9 insertions(+), 7 deletions(-)

diff --git a/google-cloud-speech/src/test/java/com/google/cloud/speech/v1/MockSpeechImpl.java b/google-cloud-speech/src/test/java/com/google/cloud/speech/v1/MockSpeechImpl.java
index 2136923d4..695c51722 100644
--- a/google-cloud-speech/src/test/java/com/google/cloud/speech/v1/MockSpeechImpl.java
+++ b/google-cloud-speech/src/test/java/com/google/cloud/speech/v1/MockSpeechImpl.java
@@ -90,11 +90,12 @@ public void longRunningRecognize(
   @Override
   public StreamObserver<StreamingRecognizeRequest> streamingRecognize(
       final StreamObserver<StreamingRecognizeResponse> responseObserver) {
-    final Object response = responses.remove();
     StreamObserver<StreamingRecognizeRequest> requestObserver =
         new StreamObserver<StreamingRecognizeRequest>() {
           @Override
           public void onNext(StreamingRecognizeRequest value) {
+            requests.add(value);
+            final Object response = responses.remove();
             if (response instanceof StreamingRecognizeResponse) {
               responseObserver.onNext((StreamingRecognizeResponse) response);
             } else if (response instanceof Exception) {
diff --git a/google-cloud-speech/src/test/java/com/google/cloud/speech/v1p1beta1/MockSpeechImpl.java b/google-cloud-speech/src/test/java/com/google/cloud/speech/v1p1beta1/MockSpeechImpl.java
index 1bc8fbf70..d052cdf11 100644
--- a/google-cloud-speech/src/test/java/com/google/cloud/speech/v1p1beta1/MockSpeechImpl.java
+++ b/google-cloud-speech/src/test/java/com/google/cloud/speech/v1p1beta1/MockSpeechImpl.java
@@ -90,11 +90,12 @@ public void longRunningRecognize(
   @Override
   public StreamObserver<StreamingRecognizeRequest> streamingRecognize(
       final StreamObserver<StreamingRecognizeResponse> responseObserver) {
-    final Object response = responses.remove();
     StreamObserver<StreamingRecognizeRequest> requestObserver =
         new StreamObserver<StreamingRecognizeRequest>() {
           @Override
           public void onNext(StreamingRecognizeRequest value) {
+            requests.add(value);
+            final Object response = responses.remove();
             if (response instanceof StreamingRecognizeResponse) {
               responseObserver.onNext((StreamingRecognizeResponse) response);
             } else if (response instanceof Exception) {
diff --git a/synth.metadata b/synth.metadata
index 0dd8041c6..0b6892fec 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -4,23 +4,23 @@
       "git": {
         "name": ".",
         "remote": "https://github.com/googleapis/java-speech.git",
-        "sha": "6dee1350b47734f3dfff19e3f3fa81a1d502253b"
+        "sha": "8fe074c183d0521a4ea645c3c498248b33d7debd"
       }
     },
     {
       "git": {
         "name": "googleapis",
         "remote": "https://github.com/googleapis/googleapis.git",
-        "sha": "4d61e1cb40184a7ad63ef37b1813f6608718674a",
-        "internalRef": "306280989"
+        "sha": "28e76243c23cc282efbb288cb558c174e3e5e9ee",
+        "internalRef": "308294748"
       }
     },
     {
       "git": {
         "name": "googleapis",
         "remote": "https://github.com/googleapis/googleapis.git",
-        "sha": "4d61e1cb40184a7ad63ef37b1813f6608718674a",
-        "internalRef": "306280989"
+        "sha": "28e76243c23cc282efbb288cb558c174e3e5e9ee",
+        "internalRef": "308294748"
       }
     },
     {