googleapis
diff --git a/‎google-cloud-spanner/src/main/java/com/google/cloud/spanner/AbstractResultSet.java‎
Lines changed: 1 addition & 7 deletions b/‎google-cloud-spanner/src/main/java/com/google/cloud/spanner/AbstractResultSet.java‎
Lines changed: 1 addition & 7 deletions
@@ -786,7 +786,7 @@ static class GrpcStreamIterator extends AbstractIterator<PartialResultSet>
     private final Statement statement;
 
     private SpannerRpc.StreamingCall call;
-    private boolean withBeginTransaction;
+    private volatile boolean withBeginTransaction;
     private SpannerException error;
 
     @VisibleForTesting
@@ -889,12 +889,6 @@ public void onError(SpannerException e) {
         error = e;
         addToStream(END_OF_STREAM);
       }
-
-      // Visible only for testing.
-      @VisibleForTesting
-      void setCall(SpannerRpc.StreamingCall call, boolean withBeginTransaction) {
-        GrpcStreamIterator.this.setCall(call, withBeginTransaction);
-      }
     }
   }
Original file line number	Diff line number	Diff line change
`@@ -786,7 +786,7 @@ static class GrpcStreamIterator extends AbstractIterator<PartialResultSet>`
`786`	`786`	`private final Statement statement;`
`787`	`787`
`788`	`788`	`private SpannerRpc.StreamingCall call;`
`789`		`- private boolean withBeginTransaction;`
	`789`	`+ private volatile boolean withBeginTransaction;`
`790`	`790`	`private SpannerException error;`
`791`	`791`
`792`	`792`	`@VisibleForTesting`
`@@ -889,12 +889,6 @@ public void onError(SpannerException e) {`
`889`	`889`	`error = e;`
`890`	`890`	`addToStream(END_OF_STREAM);`
`891`	`891`	`}`
`892`		`-`
`893`		`- // Visible only for testing.`
`894`		`- @VisibleForTesting`
`895`		`- void setCall(SpannerRpc.StreamingCall call, boolean withBeginTransaction) {`
`896`		`- GrpcStreamIterator.this.setCall(call, withBeginTransaction);`
`897`		`- }`
`898`	`892`	`}`
`899`	`893`	`}`
`900`	`894`