fix: 2.x scan ITs (#158)

Unoperate · May 11, 2022 · 46dc68b · 46dc68b
1 parent 14eabdb
commit 46dc68b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ests/src/test/java/com/google/cloud/bigtable/hbase/mirroring/TestMirroringAsyncTable.java b/...ests/src/test/java/com/google/cloud/bigtable/hbase/mirroring/TestMirroringAsyncTable.java
@@ -1409,8 +1409,8 @@ public void onComplete() {
           .getTableBuilder(tableName, this.executorServiceRule.executorService)
           .build()
           .scan(new Scan(), consumer);
+      scanConsumerEnded.get();
     }
-    scanConsumerEnded.get();
 
     assertThat(read.get()).isEqualTo(databaseEntriesCount);
   }