Skip to content
This repository was archived by the owner on Jan 22, 2024. It is now read-only.
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ public void reset() {
@Override
public void runReport(
RunReportRequest request, StreamObserver<RunReportResponse> responseObserver) {
Object response = responses.remove();
Object response = responses.poll();
if (response instanceof RunReportResponse) {
requests.add(request);
responseObserver.onNext(((RunReportResponse) response));
Expand All @@ -73,7 +73,7 @@ public void runReport(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method RunReport, expected %s or %s",
response.getClass().getName(),
response == null ? "null" : response.getClass().getName(),
RunReportResponse.class.getName(),
Exception.class.getName())));
}
Expand All @@ -82,7 +82,7 @@ public void runReport(
@Override
public void runPivotReport(
RunPivotReportRequest request, StreamObserver<RunPivotReportResponse> responseObserver) {
Object response = responses.remove();
Object response = responses.poll();
if (response instanceof RunPivotReportResponse) {
requests.add(request);
responseObserver.onNext(((RunPivotReportResponse) response));
Expand All @@ -94,7 +94,7 @@ public void runPivotReport(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method RunPivotReport, expected %s or %s",
response.getClass().getName(),
response == null ? "null" : response.getClass().getName(),
RunPivotReportResponse.class.getName(),
Exception.class.getName())));
}
Expand All @@ -103,7 +103,7 @@ public void runPivotReport(
@Override
public void batchRunReports(
BatchRunReportsRequest request, StreamObserver<BatchRunReportsResponse> responseObserver) {
Object response = responses.remove();
Object response = responses.poll();
if (response instanceof BatchRunReportsResponse) {
requests.add(request);
responseObserver.onNext(((BatchRunReportsResponse) response));
Expand All @@ -115,7 +115,7 @@ public void batchRunReports(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method BatchRunReports, expected %s or %s",
response.getClass().getName(),
response == null ? "null" : response.getClass().getName(),
BatchRunReportsResponse.class.getName(),
Exception.class.getName())));
}
Expand All @@ -125,7 +125,7 @@ public void batchRunReports(
public void batchRunPivotReports(
BatchRunPivotReportsRequest request,
StreamObserver<BatchRunPivotReportsResponse> responseObserver) {
Object response = responses.remove();
Object response = responses.poll();
if (response instanceof BatchRunPivotReportsResponse) {
requests.add(request);
responseObserver.onNext(((BatchRunPivotReportsResponse) response));
Expand All @@ -137,15 +137,15 @@ public void batchRunPivotReports(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method BatchRunPivotReports, expected %s or %s",
response.getClass().getName(),
response == null ? "null" : response.getClass().getName(),
BatchRunPivotReportsResponse.class.getName(),
Exception.class.getName())));
}
}

@Override
public void getMetadata(GetMetadataRequest request, StreamObserver<Metadata> responseObserver) {
Object response = responses.remove();
Object response = responses.poll();
if (response instanceof Metadata) {
requests.add(request);
responseObserver.onNext(((Metadata) response));
Expand All @@ -157,7 +157,7 @@ public void getMetadata(GetMetadataRequest request, StreamObserver<Metadata> res
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetMetadata, expected %s or %s",
response.getClass().getName(),
response == null ? "null" : response.getClass().getName(),
Metadata.class.getName(),
Exception.class.getName())));
}
Expand All @@ -167,7 +167,7 @@ public void getMetadata(GetMetadataRequest request, StreamObserver<Metadata> res
public void runRealtimeReport(
RunRealtimeReportRequest request,
StreamObserver<RunRealtimeReportResponse> responseObserver) {
Object response = responses.remove();
Object response = responses.poll();
if (response instanceof RunRealtimeReportResponse) {
requests.add(request);
responseObserver.onNext(((RunRealtimeReportResponse) response));
Expand All @@ -179,7 +179,7 @@ public void runRealtimeReport(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method RunRealtimeReport, expected %s or %s",
response.getClass().getName(),
response == null ? "null" : response.getClass().getName(),
RunRealtimeReportResponse.class.getName(),
Exception.class.getName())));
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ public void reset() {
@Override
public void runReport(
RunReportRequest request, StreamObserver<RunReportResponse> responseObserver) {
Object response = responses.remove();
Object response = responses.poll();
if (response instanceof RunReportResponse) {
requests.add(request);
responseObserver.onNext(((RunReportResponse) response));
Expand All @@ -73,7 +73,7 @@ public void runReport(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method RunReport, expected %s or %s",
response.getClass().getName(),
response == null ? "null" : response.getClass().getName(),
RunReportResponse.class.getName(),
Exception.class.getName())));
}
Expand All @@ -82,7 +82,7 @@ public void runReport(
@Override
public void runPivotReport(
RunPivotReportRequest request, StreamObserver<RunPivotReportResponse> responseObserver) {
Object response = responses.remove();
Object response = responses.poll();
if (response instanceof RunPivotReportResponse) {
requests.add(request);
responseObserver.onNext(((RunPivotReportResponse) response));
Expand All @@ -94,7 +94,7 @@ public void runPivotReport(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method RunPivotReport, expected %s or %s",
response.getClass().getName(),
response == null ? "null" : response.getClass().getName(),
RunPivotReportResponse.class.getName(),
Exception.class.getName())));
}
Expand All @@ -103,7 +103,7 @@ public void runPivotReport(
@Override
public void batchRunReports(
BatchRunReportsRequest request, StreamObserver<BatchRunReportsResponse> responseObserver) {
Object response = responses.remove();
Object response = responses.poll();
if (response instanceof BatchRunReportsResponse) {
requests.add(request);
responseObserver.onNext(((BatchRunReportsResponse) response));
Expand All @@ -115,7 +115,7 @@ public void batchRunReports(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method BatchRunReports, expected %s or %s",
response.getClass().getName(),
response == null ? "null" : response.getClass().getName(),
BatchRunReportsResponse.class.getName(),
Exception.class.getName())));
}
Expand All @@ -125,7 +125,7 @@ public void batchRunReports(
public void batchRunPivotReports(
BatchRunPivotReportsRequest request,
StreamObserver<BatchRunPivotReportsResponse> responseObserver) {
Object response = responses.remove();
Object response = responses.poll();
if (response instanceof BatchRunPivotReportsResponse) {
requests.add(request);
responseObserver.onNext(((BatchRunPivotReportsResponse) response));
Expand All @@ -137,15 +137,15 @@ public void batchRunPivotReports(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method BatchRunPivotReports, expected %s or %s",
response.getClass().getName(),
response == null ? "null" : response.getClass().getName(),
BatchRunPivotReportsResponse.class.getName(),
Exception.class.getName())));
}
}

@Override
public void getMetadata(GetMetadataRequest request, StreamObserver<Metadata> responseObserver) {
Object response = responses.remove();
Object response = responses.poll();
if (response instanceof Metadata) {
requests.add(request);
responseObserver.onNext(((Metadata) response));
Expand All @@ -157,7 +157,7 @@ public void getMetadata(GetMetadataRequest request, StreamObserver<Metadata> res
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetMetadata, expected %s or %s",
response.getClass().getName(),
response == null ? "null" : response.getClass().getName(),
Metadata.class.getName(),
Exception.class.getName())));
}
Expand All @@ -167,7 +167,7 @@ public void getMetadata(GetMetadataRequest request, StreamObserver<Metadata> res
public void runRealtimeReport(
RunRealtimeReportRequest request,
StreamObserver<RunRealtimeReportResponse> responseObserver) {
Object response = responses.remove();
Object response = responses.poll();
if (response instanceof RunRealtimeReportResponse) {
requests.add(request);
responseObserver.onNext(((RunRealtimeReportResponse) response));
Expand All @@ -179,7 +179,7 @@ public void runRealtimeReport(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method RunRealtimeReport, expected %s or %s",
response.getClass().getName(),
response == null ? "null" : response.getClass().getName(),
RunRealtimeReportResponse.class.getName(),
Exception.class.getName())));
}
Expand Down
10 changes: 5 additions & 5 deletions synth.metadata
Original file line number Diff line number Diff line change
Expand Up @@ -4,23 +4,23 @@
"git": {
"name": ".",
"remote": "https://github.com/googleapis/java-analytics-data.git",
"sha": "cfd43f0a854379ad2161c1af8a709ebfb96196bd"
"sha": "799d067f64da2b01b30aa7d8dfa7a7aa5143c2da"
}
},
{
"git": {
"name": "googleapis-gen",
"remote": "https://github.com/googleapis/googleapis-gen.git",
"sha": "ba5ec70708cd72caa1692a95ce57891e3ade61dd",
"internalRef": "361377784"
"sha": "ebd77e76effb65c4fba8c64f31c15062c250a4c2",
"internalRef": "362856902"
}
},
{
"git": {
"name": "googleapis-gen",
"remote": "https://github.com/googleapis/googleapis-gen.git",
"sha": "ba5ec70708cd72caa1692a95ce57891e3ade61dd",
"internalRef": "361377784"
"sha": "ebd77e76effb65c4fba8c64f31c15062c250a4c2",
"internalRef": "362856902"
}
},
{
Expand Down