Fix some compile issues; use new loop method

propensive · Mar 16, 2024 · b1a636f · b1a636f
1 parent dd84735
commit b1a636f
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/src/core/socket.scala b/src/core/socket.scala
@@ -297,18 +297,18 @@ extension [SocketType](socket: SocketType)
           : SocketService raises BindError =
 
     val binding = bindable.bind(socket)
-    var continue: Boolean = true
 
-    val async = Async:
-      while continue do
-        val connection = bindable.connect(binding)
-        Async(bindable.transmit(binding, connection, lambda(connection)))
+    val bindLoop = loop:
+      val connection = bindable.connect(binding)
+      async(bindable.transmit(binding, connection, lambda(connection)))
+
+    val task = async(bindLoop.start())
 
     new SocketService:
       def stop(): Unit =
-        continue = false
+        bindLoop.stop()
         bindable.stop(binding)
-        safely(async.await())
+        safely(task.await())
 
 extension [EndpointType](endpoint: EndpointType)
   def connect[StateType](initialState: StateType)[MessageType](initialMessage: MessageType = Bytes())