Skip to content

Commit 7037180

Browse files
fix(spanner): unflake unit tests
1 parent 6225efa commit 7037180

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,10 +65,11 @@ abstract class ResumableStreamIterator extends AbstractIterator<PartialResultSet
6565
private static final Logger logger = Logger.getLogger(ResumableStreamIterator.class.getName());
6666
private BackOff backOff;
6767
private final LinkedList<PartialResultSet> buffer = new LinkedList<>();
68+
private final Object monitor = new Object();
6869
private final int maxBufferSize;
6970
private final ISpan span;
7071
private final TraceWrapper tracer;
71-
private CloseableIterator<PartialResultSet> stream;
72+
private volatile CloseableIterator<PartialResultSet> stream;
7273
private ByteString resumeToken;
7374
private boolean finished;
7475
/**

0 commit comments

Comments
 (0)