Skip to content

Commit 57d3ad5

Browse files
committed
Rename rwTxn to readWriteTxn
1 parent a5f7ceb commit 57d3ad5

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

samples/snippets/src/main/java/com/example/spanner/ChangeStreamsTxnExclusionSample.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,12 +38,12 @@ static void setExcludeTxnFromChangeStreams() {
3838
SpannerOptions.newBuilder().setProjectId(projectId).build().getService()) {
3939
final DatabaseClient databaseClient =
4040
spanner.getDatabaseClient(DatabaseId.of(projectId, instanceId, databaseId));
41-
rwTxnExcludedFromChangeStreams(databaseClient);
41+
readWriteTxnExcludedFromChangeStreams(databaseClient);
4242
}
4343
}
4444

4545
// [START spanner_set_exclude_txn_from_change_streams]
46-
static void rwTxnExcludedFromChangeStreams(DatabaseClient client) {
46+
static void readWriteTxnExcludedFromChangeStreams(DatabaseClient client) {
4747
// Exclude the transaction from allowed tracking change streams with alloww_txn_exclusion=true.
4848
// This exclusion will be applied to all the individual operations inside this transaction.
4949
client

samples/snippets/src/test/java/com/example/spanner/ChangeStreamsTxnExclusionSampleIT.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,8 @@ public void removeTestData() {
9090
public void testSetExcludeTxnFromChangeStreamsSampleSample() throws Exception {
9191
final DatabaseClient client = spanner.getDatabaseClient(databaseId);
9292
String out =
93-
runSample(() -> ChangeStreamsTxnExclusionSample.rwTxnExcludedFromChangeStreams(client));
93+
runSample(
94+
() -> ChangeStreamsTxnExclusionSample.readWriteTxnExcludedFromChangeStreams(client));
9495
assertThat(out).contains("New singer inserted.");
9596
assertThat(out).contains("Singer first name updated.");
9697
}

0 commit comments

Comments
 (0)