@@ -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