fix(generator): delay removing streaming response until used (#145)

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: googleapis/googleapis@28e7624

Author: yoshi-automation

google-cloud-video-intelligence/src/test/java/com/google/cloud/videointelligence/v1p3beta1/MockStreamingVideoIntelligenceServiceImpl.java

@@ -60,11 +60,12 @@ public void reset() {
  @Override
  public StreamObserver<StreamingAnnotateVideoRequest> streamingAnnotateVideo(
  final StreamObserver<StreamingAnnotateVideoResponse> responseObserver) {
- final Object response = responses.remove();
  StreamObserver<StreamingAnnotateVideoRequest> requestObserver =
  new StreamObserver<StreamingAnnotateVideoRequest>() {
  @Override
  public void onNext(StreamingAnnotateVideoRequest value) {
+ requests.add(value);
+ final Object response = responses.remove();
  if (response instanceof StreamingAnnotateVideoResponse) {
  responseObserver.onNext((StreamingAnnotateVideoResponse) response);
  } else if (response instanceof Exception) {

synth.metadata

@@ -4,15 +4,15 @@
  "git": {
  "name": ".",
  "remote": "https://github.com/googleapis/java-video-intelligence.git",
- "sha": "1827e5dce4d41447ea50302e121047e767d12aed"
+ "sha": "a65905927826c82e7bdcca025e18021259e4dd1e"
  }
  },
  {
  "git": {
  "name": "googleapis",
  "remote": "https://github.com/googleapis/googleapis.git",
- "sha": "96c0db42dbcb3bb0116cfa55c054dd139ffb3912",
- "internalRef": "305779873"
+ "sha": "28e76243c23cc282efbb288cb558c174e3e5e9ee",
+ "internalRef": "308294748"
  }
  },
  {