add sync block

sakthivelmanii · sakthivelmanii · commit 2b273f9b613a · 2025-01-06T18:23:26.000+05:30
diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/AsyncResultSetImpl.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/AsyncResultSetImpl.java
@@ -469,7 +469,7 @@ public void run() {
         // Non-streaming result sets do not trigger this callback, and for those result sets, we
         // need to eagerly start the ProduceRowsRunnable.
         synchronized (monitor) {
-          if (!(state == State.STREAMING_INITIALIZED)) {
+          if (state == State.RUNNING || state == State.CONSUMING) {
             return;
           }
         }

Original file line number	Diff line number	Diff line change
`@@ -469,7 +469,7 @@ public void run() {`
`469`	`469`	`// Non-streaming result sets do not trigger this callback, and for those result sets, we`
`470`	`470`	`// need to eagerly start the ProduceRowsRunnable.`
`471`	`471`	`synchronized (monitor) {`
`472`		`- if (!(state == State.STREAMING_INITIALIZED)) {`
	`472`	`+ if (state == State.RUNNING \|\| state == State.CONSUMING) {`
`473`	`473`	`return;`
`474`	`474`	`}`
`475`	`475`	`}`