verify fix with adding latency

Author: sakthivelmanii

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

@@ -516,11 +516,6 @@ private void initiateProduceRows() {
       }
       produceRowsInitiated = true;
     }
-    try {
-      Thread.sleep(5L);
-    } catch (InterruptedException e) {
-      throw new RuntimeException(e);
-    }
     this.service.execute(new ProduceRowsRunnable());
   }
 

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

@@ -321,8 +321,8 @@ && prepareIteratorForRetryOnDifferentGrpcChannel()) {
   private void startGrpcStreaming() {
     //    synchronized (monitor) {
     System.out.printf(
-        "[%s][%s] Inside startGrpcStreaming\n",
-        OffsetDateTime.now(), Thread.currentThread().getName());
+        "[%s][%s] Inside startGrpcStreaming %s\n",
+        OffsetDateTime.now(), Thread.currentThread().getName(), stream);
     if (stream == null) {
       span.addAnnotation(
           "Starting/Resuming stream",
@@ -332,9 +332,12 @@ private void startGrpcStreaming() {
         // When start a new stream set the Span as current to make the gRPC Span a child of
         // this Span.
         System.out.printf(
-            "[%s][%s] Inside creating stream\n",
-            OffsetDateTime.now(), Thread.currentThread().getName());
+            "[%s][%s] Inside creating stream %s\n",
+            OffsetDateTime.now(), Thread.currentThread().getName(), stream);
         stream = checkNotNull(startStream(resumeToken, streamMessageListener));
+        System.out.printf(
+            "[%s][%s] Stream created %s\n",
+            OffsetDateTime.now(), Thread.currentThread().getName(), stream);
       }
     }
     //    }