diff --git a/README.md b/README.md index dcfd9cf6af..2ef6f4587c 100644 --- a/README.md +++ b/README.md @@ -20,7 +20,7 @@ If you are using Maven with [BOM][libraries-bom], add this to your pom.xml file com.google.cloud libraries-bom - 4.4.1 + 5.1.0 pom import diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/MockBigQueryWriteImpl.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/MockBigQueryWriteImpl.java index a82a3dbdb3..32e15e28d0 100644 --- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/MockBigQueryWriteImpl.java +++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/MockBigQueryWriteImpl.java @@ -83,12 +83,11 @@ public void createWriteStream( @Override public StreamObserver appendRows( final StreamObserver responseObserver) { + final Object response = responses.remove(); StreamObserver requestObserver = new StreamObserver() { @Override public void onNext(AppendRowsRequest value) { - requests.add(value); - final Object response = responses.remove(); if (response instanceof AppendRowsResponse) { responseObserver.onNext((AppendRowsResponse) response); } else if (response instanceof Exception) { diff --git a/synth.metadata b/synth.metadata index db492867f5..677205f0df 100644 --- a/synth.metadata +++ b/synth.metadata @@ -11,7 +11,7 @@ "git": { "name": ".", "remote": "https://github.com/googleapis/java-bigquerystorage.git", - "sha": "a0db93e9d1f714a68dd11ef38c782099701dd068" + "sha": "532a698193542b0a5db03d2e29a415082f2de95b" } }, {