From 426aeec3ea4e059e77a06ef2a073a0a165a45d69 Mon Sep 17 00:00:00 2001
From: Mike Barry <msb5014@gmail.com>
Date: Fri, 23 Apr 2021 08:12:42 -0400
Subject: [PATCH] fix

---
 .../com/onthegomap/flatmap/worker/TopologyTest.java    | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

diff --git a/src/test/java/com/onthegomap/flatmap/worker/TopologyTest.java b/src/test/java/com/onthegomap/flatmap/worker/TopologyTest.java
index 4e8f8590..90decb88 100644
--- a/src/test/java/com/onthegomap/flatmap/worker/TopologyTest.java
+++ b/src/test/java/com/onthegomap/flatmap/worker/TopologyTest.java
@@ -55,13 +55,11 @@ public class TopologyTest {
       }).addBuffer("writer_queue", 1)
       .sinkToConsumer("writer", 1, result::add);
 
-    new Thread(() -> {
-      queue.accept(0);
-      queue.accept(1);
-      queue.close();
-    }).start();
+    queue.accept(0);
+    queue.accept(1);
+    queue.close();
 
-    topology.awaitAndLog(new ProgressLoggers("test"), Duration.ofSeconds(30));
+    topology.await();
 
     assertEquals(Set.of(1, 2, 3, 4), result);
   }