Add more logs

Author: sakthivelmanii

google-cloud-spanner/src/main/java/com/google/cloud/spanner/AsyncResultSetImpl.java

@@ -52,6 +52,7 @@ class AsyncResultSetImpl extends ForwardingStructReader
   private enum State {
     INITIALIZED,
     STREAMING_INITIALIZED,
+    STREAMING_STARTED,
     /** SYNC indicates that the {@link ResultSet} is used in sync pattern. */
     SYNC,
     CONSUMING,
@@ -469,10 +470,10 @@ 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.STREAMING_STARTED || state == State.RUNNING || state == State.CONSUMING) {
             return;
           }
-          state = State.STREAMING_INITIALIZED;
+          state = State.STREAMING_STARTED;
           System.out.printf("State: %s\n", state);
           if (!initiateStreaming(AsyncResultSetImpl.this)) {
             initiateProduceRows();
@@ -495,6 +496,7 @@ public ApiFuture<Void> setCallback(Executor exec, ReadyCallback cb) {
 
       // Start to fetch data and buffer these.
       this.result = SettableApiFuture.create();
+      this.state = State.STREAMING_INITIALIZED;
       this.service.execute(new InitiateStreamingRunnable());
       this.executor = MoreExecutors.newSequentialExecutor(Preconditions.checkNotNull(exec));
       this.callback = Preconditions.checkNotNull(cb);
@@ -505,7 +507,7 @@ public ApiFuture<Void> setCallback(Executor exec, ReadyCallback cb) {
 
   private void initiateProduceRows() {
     synchronized (monitor) {
-      if (this.state == State.STREAMING_INITIALIZED) {
+      if (this.state == State.STREAMING_STARTED) {
         this.state = State.RUNNING;
       }
       produceRowsInitiated = true;