minor refactoring

getkyo · Jan 21, 2025 · 63629cd · 63629cd
1 parent 29a6f82
commit 63629cd
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/kyo-core/shared/src/main/scala/kyo/Hub.scala b/kyo-core/shared/src/main/scala/kyo/Hub.scala
@@ -173,11 +173,6 @@ final class Hub[A] private[kyo] (
         }
     end listen
 
-    private[kyo] def remove(listener: Listener[A])(using Frame): Unit < IO =
-        IO {
-            discard(listeners.remove(listener))
-        }
-
     /** Puts multiple elements into the Hub as a batch.
       *
       * @param values
@@ -202,6 +197,11 @@ final class Hub[A] private[kyo] (
       *   Chunk containing up to max elements
       */
     def drainUpTo(max: Int)(using Frame): Chunk[A] < (IO & Abort[Closed]) = ch.drainUpTo(max)
+
+    private[kyo] def remove(listener: Listener[A])(using Frame): Unit < IO =
+        IO {
+            discard(listeners.remove(listener))
+        }
 end Hub
 
 object Hub: