Skip to content

Commit 816c5ee

Browse files
chore: generate libraries at Mon Jan 6 14:26:28 UTC 2025
1 parent 7a96270 commit 816c5ee

File tree

2 files changed

+10
-9
lines changed

2 files changed

+10
-9
lines changed

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

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -470,14 +470,14 @@ public void run() {
470470
// Non-streaming result sets do not trigger this callback, and for those result sets, we
471471
// need to eagerly start the ProduceRowsRunnable.
472472
synchronized (monitor) {
473-
// if (state == State.STREAMING_IN_PROGRESS
474-
// || state == State.RUNNING
475-
// || state == State.CONSUMING) {
476-
// return;
477-
// }
478-
// if (state == State.STREAMING_INITIALIZED) {
479-
// state = State.STREAMING_IN_PROGRESS;
480-
// }
473+
// if (state == State.STREAMING_IN_PROGRESS
474+
// || state == State.RUNNING
475+
// || state == State.CONSUMING) {
476+
// return;
477+
// }
478+
// if (state == State.STREAMING_INITIALIZED) {
479+
// state = State.STREAMING_IN_PROGRESS;
480+
// }
481481
if (!initiateStreaming(AsyncResultSetImpl.this)) {
482482
initiateProduceRows();
483483
}

google-cloud-spanner/src/test/java/com/google/cloud/spanner/MockSpannerServiceImpl.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2000,7 +2000,8 @@ private void ensureMostRecentTransaction(Session session, ByteString transaction
20002000
if (index > -1) {
20012001
long id = Long.parseLong(transactionId.toStringUtf8().substring(index + 1));
20022002
if (id != counter.get()) {
2003-
System.out.printf("Session ID %s TransactionId %s\n", session.getName(), transactionId.toStringUtf8());
2003+
System.out.printf(
2004+
"Session ID %s TransactionId %s\n", session.getName(), transactionId.toStringUtf8());
20042005
throw Status.FAILED_PRECONDITION
20052006
.withDescription(
20062007
String.format(

0 commit comments

Comments
 (0)