fix build

getkyo · Nov 27, 2023 · 892bb48 · 892bb48
1 parent 9f0f61e
commit 892bb48
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/kyo-core/shared/src/main/scala/kyo/concurrent/hubs.scala b/kyo-core/shared/src/main/scala/kyo/concurrent/hubs.scala
@@ -7,6 +7,7 @@ import kyo.concurrent.fibers._
 import kyo.concurrent.channels._
 import java.util.concurrent.ConcurrentSkipListSet
 import java.util.concurrent.CopyOnWriteArraySet
+import Flat.unsafe._
 
 object hubs {
 
@@ -30,7 +31,7 @@ object hubs {
               }
             loop()
           }.map { fiber =>
-            new Hub(ch, fiber, listeners)
+            new Hub(ch, fiber, listeners)(f)
           }
         }
       }