fix

Author: sakthivelmanii

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

@@ -479,11 +479,14 @@ public void run() {
         //          if (state == State.STREAMING_INITIALIZED) {
         //            state = State.STREAMING_IN_PROGRESS;
         //          }
+        System.out.println("InitiateStreamingRunnable");
         if (!initiateStreaming(AsyncResultSetImpl.this)) {
+          System.out.println("Inside if initiateProduceRows");
           initiateProduceRows();
         }
         //        }
       } catch (Throwable exception) {
+        System.out.println("exception initiateProduceRows");
         executionException = SpannerExceptionFactory.asSpannerException(exception);
         initiateProduceRows();
       }
@@ -652,6 +655,7 @@ public Struct getCurrentRowAsStruct() {
 
   @Override
   public void onStreamMessage(PartialResultSet partialResultSet, boolean bufferIsFull) {
+    System.out.println("onStreamMessage");
     synchronized (monitor) {
       if (produceRowsInitiated) {
         return;