Skip to content
This repository was archived by the owner on May 8, 2026. It is now read-only.

Commit 898bc0d

Browse files
chore: generate libraries at Fri Feb 13 03:09:45 UTC 2026
1 parent e628293 commit 898bc0d

1 file changed

Lines changed: 10 additions & 15 deletions

File tree

test-proxy/src/main/java/com/google/cloud/bigtable/testproxy/CbtTestProxy.java

Lines changed: 10 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -289,8 +289,7 @@ public void mutateRow(
289289
// This response is empty.
290290
client.dataClient().mutateRow(mutation);
291291
} catch (ApiException e) {
292-
responseObserver.onNext(
293-
MutateRowResult.newBuilder().setStatus(convertStatus(e)).build());
292+
responseObserver.onNext(MutateRowResult.newBuilder().setStatus(convertStatus(e)).build());
294293
responseObserver.onCompleted();
295294
return;
296295
} catch (StatusRuntimeException e) {
@@ -342,8 +341,7 @@ public void bulkMutateRows(
342341
responseObserver.onCompleted();
343342
return;
344343
} catch (ApiException e) {
345-
responseObserver.onNext(
346-
MutateRowsResult.newBuilder().setStatus(convertStatus(e)).build());
344+
responseObserver.onNext(MutateRowsResult.newBuilder().setStatus(convertStatus(e)).build());
347345
responseObserver.onCompleted();
348346
return;
349347
} catch (StatusRuntimeException e) {
@@ -395,8 +393,7 @@ public void readRow(ReadRowRequest request, StreamObserver<RowResult> responseOb
395393
logger.info(String.format("readRow() did not find row: %s", request.getRowKey()));
396394
}
397395
} catch (ApiException e) {
398-
responseObserver.onNext(
399-
RowResult.newBuilder().setStatus(convertStatus(e)).build());
396+
responseObserver.onNext(RowResult.newBuilder().setStatus(convertStatus(e)).build());
400397
responseObserver.onCompleted();
401398
return;
402399
} catch (StatusRuntimeException e) {
@@ -440,8 +437,7 @@ public void readRows(ReadRowsRequest request, StreamObserver<RowsResult> respons
440437
// Note that the default instance == OK
441438
resultBuilder.setStatus(com.google.rpc.Status.getDefaultInstance()).build());
442439
} catch (ApiException e) {
443-
responseObserver.onNext(
444-
RowsResult.newBuilder().setStatus(convertStatus(e)).build());
440+
responseObserver.onNext(RowsResult.newBuilder().setStatus(convertStatus(e)).build());
445441
responseObserver.onCompleted();
446442
return;
447443
} catch (StatusRuntimeException e) {
@@ -558,8 +554,7 @@ public void sampleRowKeys(
558554
try {
559555
keyOffsets = client.dataClient().sampleRowKeys(tableId);
560556
} catch (ApiException e) {
561-
responseObserver.onNext(
562-
SampleRowKeysResult.newBuilder().setStatus(convertStatus(e)).build());
557+
responseObserver.onNext(SampleRowKeysResult.newBuilder().setStatus(convertStatus(e)).build());
563558
responseObserver.onCompleted();
564559
return;
565560
} catch (StatusRuntimeException e) {
@@ -643,8 +638,7 @@ public void readModifyWriteRow(
643638
"readModifyWriteRow() did not find row: %s", request.getRequest().getRowKey()));
644639
}
645640
} catch (ApiException e) {
646-
responseObserver.onNext(
647-
RowResult.newBuilder().setStatus(convertStatus(e)).build());
641+
responseObserver.onNext(RowResult.newBuilder().setStatus(convertStatus(e)).build());
648642
responseObserver.onCompleted();
649643
return;
650644
} catch (StatusRuntimeException e) {
@@ -700,8 +694,7 @@ public void executeQuery(
700694
responseObserver.onError(e);
701695
return;
702696
} catch (ApiException e) {
703-
responseObserver.onNext(
704-
ExecuteQueryResult.newBuilder().setStatus(convertStatus(e)).build());
697+
responseObserver.onNext(ExecuteQueryResult.newBuilder().setStatus(convertStatus(e)).build());
705698
responseObserver.onCompleted();
706699
return;
707700
} catch (StatusRuntimeException e) {
@@ -803,7 +796,9 @@ private static com.google.rpc.Status convertStatus(ApiException e) {
803796
return status;
804797
}
805798

806-
return com.google.rpc.Status.newBuilder().setCode(e.getStatusCode().getCode().ordinal()).setMessage(e.getMessage())
799+
return com.google.rpc.Status.newBuilder()
800+
.setCode(e.getStatusCode().getCode().ordinal())
801+
.setMessage(e.getMessage())
807802
.build();
808803
}
809804

0 commit comments

Comments
 (0)