diff --git a/google-cloud-gkehub/src/main/java/com/google/cloud/gkehub/v1beta1/GkeHubMembershipServiceClient.java b/google-cloud-gkehub/src/main/java/com/google/cloud/gkehub/v1beta1/GkeHubMembershipServiceClient.java index 8835b270..692c2ad4 100644 --- a/google-cloud-gkehub/src/main/java/com/google/cloud/gkehub/v1beta1/GkeHubMembershipServiceClient.java +++ b/google-cloud-gkehub/src/main/java/com/google/cloud/gkehub/v1beta1/GkeHubMembershipServiceClient.java @@ -268,6 +268,14 @@ public final ListMembershipsPagedResponse listMemberships(ListMembershipsRequest *
{@code * try (GkeHubMembershipServiceClient gkeHubMembershipServiceClient = * GkeHubMembershipServiceClient.create()) { + * ListMembershipsRequest request = + * ListMembershipsRequest.newBuilder() + * .setParent("parent-995424086") + * .setPageSize(883849137) + * .setPageToken("pageToken873572522") + * .setFilter("filter-1274492040") + * .setOrderBy("orderBy-1207110587") + * .build(); * while (true) { * ListMembershipsResponse response = * gkeHubMembershipServiceClient.listMembershipsCallable().call(request); diff --git a/google-cloud-gkehub/src/test/java/com/google/cloud/gkehub/v1beta1/MockGkeHubMembershipServiceImpl.java b/google-cloud-gkehub/src/test/java/com/google/cloud/gkehub/v1beta1/MockGkeHubMembershipServiceImpl.java index 99dac991..f58e48db 100644 --- a/google-cloud-gkehub/src/test/java/com/google/cloud/gkehub/v1beta1/MockGkeHubMembershipServiceImpl.java +++ b/google-cloud-gkehub/src/test/java/com/google/cloud/gkehub/v1beta1/MockGkeHubMembershipServiceImpl.java @@ -62,7 +62,7 @@ public void reset() { @Override public void listMemberships( ListMembershipsRequest request, StreamObserverresponseObserver) { - Object response = responses.remove(); + Object response = responses.poll(); if (response instanceof ListMembershipsResponse) { requests.add(request); responseObserver.onNext(((ListMembershipsResponse) response)); @@ -74,7 +74,7 @@ public void listMemberships( new IllegalArgumentException( String.format( "Unrecognized response type %s for method ListMemberships, expected %s or %s", - response.getClass().getName(), + response == null ? "null" : response.getClass().getName(), ListMembershipsResponse.class.getName(), Exception.class.getName()))); } @@ -83,7 +83,7 @@ public void listMemberships( @Override public void getMembership( GetMembershipRequest request, StreamObserver responseObserver) { - Object response = responses.remove(); + Object response = responses.poll(); if (response instanceof Membership) { requests.add(request); responseObserver.onNext(((Membership) response)); @@ -95,7 +95,7 @@ public void getMembership( new IllegalArgumentException( String.format( "Unrecognized response type %s for method GetMembership, expected %s or %s", - response.getClass().getName(), + response == null ? "null" : response.getClass().getName(), Membership.class.getName(), Exception.class.getName()))); } @@ -104,7 +104,7 @@ public void getMembership( @Override public void createMembership( CreateMembershipRequest request, StreamObserver responseObserver) { - Object response = responses.remove(); + Object response = responses.poll(); if (response instanceof Operation) { requests.add(request); responseObserver.onNext(((Operation) response)); @@ -116,7 +116,7 @@ public void createMembership( new IllegalArgumentException( String.format( "Unrecognized response type %s for method CreateMembership, expected %s or %s", - response.getClass().getName(), + response == null ? "null" : response.getClass().getName(), Operation.class.getName(), Exception.class.getName()))); } @@ -125,7 +125,7 @@ public void createMembership( @Override public void deleteMembership( DeleteMembershipRequest request, StreamObserver responseObserver) { - Object response = responses.remove(); + Object response = responses.poll(); if (response instanceof Operation) { requests.add(request); responseObserver.onNext(((Operation) response)); @@ -137,7 +137,7 @@ public void deleteMembership( new IllegalArgumentException( String.format( "Unrecognized response type %s for method DeleteMembership, expected %s or %s", - response.getClass().getName(), + response == null ? "null" : response.getClass().getName(), Operation.class.getName(), Exception.class.getName()))); } @@ -146,7 +146,7 @@ public void deleteMembership( @Override public void updateMembership( UpdateMembershipRequest request, StreamObserver responseObserver) { - Object response = responses.remove(); + Object response = responses.poll(); if (response instanceof Operation) { requests.add(request); responseObserver.onNext(((Operation) response)); @@ -158,7 +158,7 @@ public void updateMembership( new IllegalArgumentException( String.format( "Unrecognized response type %s for method UpdateMembership, expected %s or %s", - response.getClass().getName(), + response == null ? "null" : response.getClass().getName(), Operation.class.getName(), Exception.class.getName()))); } @@ -168,7 +168,7 @@ public void updateMembership( public void generateConnectManifest( GenerateConnectManifestRequest request, StreamObserver responseObserver) { - Object response = responses.remove(); + Object response = responses.poll(); if (response instanceof GenerateConnectManifestResponse) { requests.add(request); responseObserver.onNext(((GenerateConnectManifestResponse) response)); @@ -180,7 +180,7 @@ public void generateConnectManifest( new IllegalArgumentException( String.format( "Unrecognized response type %s for method GenerateConnectManifest, expected %s or %s", - response.getClass().getName(), + response == null ? "null" : response.getClass().getName(), GenerateConnectManifestResponse.class.getName(), Exception.class.getName()))); } @@ -190,7 +190,7 @@ public void generateConnectManifest( public void validateExclusivity( ValidateExclusivityRequest request, StreamObserver responseObserver) { - Object response = responses.remove(); + Object response = responses.poll(); if (response instanceof ValidateExclusivityResponse) { requests.add(request); responseObserver.onNext(((ValidateExclusivityResponse) response)); @@ -202,7 +202,7 @@ public void validateExclusivity( new IllegalArgumentException( String.format( "Unrecognized response type %s for method ValidateExclusivity, expected %s or %s", - response.getClass().getName(), + response == null ? "null" : response.getClass().getName(), ValidateExclusivityResponse.class.getName(), Exception.class.getName()))); } @@ -212,7 +212,7 @@ public void validateExclusivity( public void generateExclusivityManifest( GenerateExclusivityManifestRequest request, StreamObserver responseObserver) { - Object response = responses.remove(); + Object response = responses.poll(); if (response instanceof GenerateExclusivityManifestResponse) { requests.add(request); responseObserver.onNext(((GenerateExclusivityManifestResponse) response)); @@ -224,7 +224,7 @@ public void generateExclusivityManifest( new IllegalArgumentException( String.format( "Unrecognized response type %s for method GenerateExclusivityManifest, expected %s or %s", - response.getClass().getName(), + response == null ? "null" : response.getClass().getName(), GenerateExclusivityManifestResponse.class.getName(), Exception.class.getName()))); } diff --git a/synth.metadata b/synth.metadata index a20d8b2a..3fe1332f 100644 --- a/synth.metadata +++ b/synth.metadata @@ -4,15 +4,15 @@ "git": { "name": ".", "remote": "https://github.com/googleapis/java-gkehub.git", - "sha": "49ce588e52c6112a9cc6c536546e9efb85ec44bd" + "sha": "6a6dc3ab087be554d59d4d0149c03cb59fd991eb" } }, { "git": { "name": "googleapis-gen", "remote": "https://github.com/googleapis/googleapis-gen.git", - "sha": "ba5ec70708cd72caa1692a95ce57891e3ade61dd", - "internalRef": "361377784" + "sha": "ebd77e76effb65c4fba8c64f31c15062c250a4c2", + "internalRef": "362856902" } }, {