We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 29b002e commit 21df16dCopy full SHA for 21df16d
1 file changed
google/cloud/spanner/internal/partial_result_set_source.cc
@@ -45,6 +45,14 @@ StatusOr<spanner::Row> PartialResultSetSource::NextRow() {
45
return spanner::Row();
46
}
47
48
+ // TODO(#8523): This assumes that we can yield a row as soon as we have
49
+ // all of its columns, which would not be the case if we (1) want to be
50
+ // able to resume interrupted streams, and (2) do not yet have a resume
51
+ // token that is "past" the row. That is, we should not yield a row that
52
+ // might be replayed. Given that we want to support resumption, for now
53
+ // we assume we always have a resume token that is "past" any completed
54
+ // row, but that needs to be verified.
55
+
56
while (buffer_.empty() || buffer_.size() < columns_->size()) {
57
auto status = ReadFromStream();
58
if (!status.ok()) {
0 commit comments