File tree Expand file tree Collapse file tree 1 file changed +13
-13
lines changed
google-cloud-spanner/src/main/java/com/google/cloud/spanner Expand file tree Collapse file tree 1 file changed +13
-13
lines changed Original file line number Diff line number Diff line change @@ -470,19 +470,19 @@ public void run() {
470
470
// Those result sets will trigger initiateProduceRows() when the first results are received.
471
471
// Non-streaming result sets do not trigger this callback, and for those result sets, we
472
472
// need to eagerly start the ProduceRowsRunnable.
473
- // synchronized (monitor) {
474
- // if (state == State.STREAMING_IN_PROGRESS
475
- // || state == State.RUNNING
476
- // || state == State.CONSUMING) {
477
- // return;
478
- // }
479
- // if (state == State.STREAMING_INITIALIZED) {
480
- // state = State.STREAMING_IN_PROGRESS;
481
- // }
482
- if (!initiateStreaming (AsyncResultSetImpl .this )) {
483
- initiateProduceRows ();
484
- }
485
- // }
473
+ // synchronized (monitor) {
474
+ // if (state == State.STREAMING_IN_PROGRESS
475
+ // || state == State.RUNNING
476
+ // || state == State.CONSUMING) {
477
+ // return;
478
+ // }
479
+ // if (state == State.STREAMING_INITIALIZED) {
480
+ // state = State.STREAMING_IN_PROGRESS;
481
+ // }
482
+ if (!initiateStreaming (AsyncResultSetImpl .this )) {
483
+ initiateProduceRows ();
484
+ }
485
+ // }
486
486
} catch (Throwable exception ) {
487
487
executionException = SpannerExceptionFactory .asSpannerException (exception );
488
488
initiateProduceRows ();
You can’t perform that action at this time.
0 commit comments