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() {
470470 // Those result sets will trigger initiateProduceRows() when the first results are received.
471471 // Non-streaming result sets do not trigger this callback, and for those result sets, we
472472 // 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+ // }
486486 } catch (Throwable exception ) {
487487 executionException = SpannerExceptionFactory .asSpannerException (exception );
488488 initiateProduceRows ();
You can’t perform that action at this time.
0 commit comments