Skip to content

Commit

Permalink
Directly add streamwriter to list in connection worker pool test
Browse files Browse the repository at this point in the history
  • Loading branch information
Evan Greco committed Nov 8, 2023
1 parent fdf20d6 commit d083ac0
Showing 1 changed file with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -389,16 +389,15 @@ public void testCloseExternalClient()
// Create some stream writers.
List<StreamWriter> streamWriterList = new ArrayList<>();
for (int i = 0; i < 4; i++) {
StreamWriter sw =
streamWriterList.add(
StreamWriter.newBuilder(
String.format("projects/p1/datasets/d1/tables/t%s/streams/_default", i),
externalClient)
.setEnableConnectionPool(true)
.setWriterSchema(createProtoSchema())
.setTraceId(TEST_TRACE_ID)
.setLocation("us")
.build();
streamWriterList.add(sw);
.build());
}

for (long i = 0; i < appendCount; i++) {
Expand Down

0 comments on commit d083ac0

Please sign in to comment.