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

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
---
 .../v1beta1/MockSpeechTranslationServiceImpl.java           | 3 ++-
 synth.metadata                                              | 6 +++---
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/google-cloud-mediatranslation/src/test/java/com/google/cloud/mediatranslation/v1beta1/MockSpeechTranslationServiceImpl.java b/google-cloud-mediatranslation/src/test/java/com/google/cloud/mediatranslation/v1beta1/MockSpeechTranslationServiceImpl.java
index 1dc8a6d9..11ca8bf6 100644
--- a/google-cloud-mediatranslation/src/test/java/com/google/cloud/mediatranslation/v1beta1/MockSpeechTranslationServiceImpl.java
+++ b/google-cloud-mediatranslation/src/test/java/com/google/cloud/mediatranslation/v1beta1/MockSpeechTranslationServiceImpl.java
@@ -59,11 +59,12 @@ public void reset() {
   @Override
   public StreamObserver<StreamingTranslateSpeechRequest> streamingTranslateSpeech(
       final StreamObserver<StreamingTranslateSpeechResponse> responseObserver) {
-    final Object response = responses.remove();
     StreamObserver<StreamingTranslateSpeechRequest> requestObserver =
         new StreamObserver<StreamingTranslateSpeechRequest>() {
           @Override
           public void onNext(StreamingTranslateSpeechRequest value) {
+            requests.add(value);
+            final Object response = responses.remove();
             if (response instanceof StreamingTranslateSpeechResponse) {
               responseObserver.onNext((StreamingTranslateSpeechResponse) response);
             } else if (response instanceof Exception) {
diff --git a/synth.metadata b/synth.metadata
index 243c6681..9d3d1292 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -4,15 +4,15 @@
       "git": {
         "name": ".",
         "remote": "https://github.com/googleapis/java-mediatranslation.git",
-        "sha": "a9a290206a5f8cddf1e0420f506b51c4bee935d8"
+        "sha": "fb49f5211dbf116a9631a01bfe15bfcfe7583187"
       }
     },
     {
       "git": {
         "name": "googleapis",
         "remote": "https://github.com/googleapis/googleapis.git",
-        "sha": "d741cd976975c745d0199987aff0e908b8352992",
-        "internalRef": "305561906"
+        "sha": "28e76243c23cc282efbb288cb558c174e3e5e9ee",
+        "internalRef": "308294748"
       }
     },
     {