diff --git a/README.md b/README.md index 2bdc78d957..4d80fc34bf 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 @@ -41,7 +41,7 @@ If you are using Maven without BOM, add this to your dependencies: com.google.cloud google-cloud-bigquerystorage - 0.128.1-beta + 0.130.0-beta ``` 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..0660033a07 100644 --- a/synth.metadata +++ b/synth.metadata @@ -11,7 +11,7 @@ "git": { "name": ".", "remote": "https://github.com/googleapis/java-bigquerystorage.git", - "sha": "a0db93e9d1f714a68dd11ef38c782099701dd068" + "sha": "d898a61f1c48e763e37a234364ee1a590187e8ec" } }, {