Provide async server sockets on MoarVM.

rakudo · Apr 20, 2014 · c4efc57 · c4efc57
1 parent 25e2ff4
commit c4efc57
Showing 1 changed file with 19 additions and 0 deletions.
diff --git a/src/core/IO/Socket/Async.pm b/src/core/IO/Socket/Async.pm
@@ -87,4 +87,23 @@ my class IO::Socket::Async {
             $host, $port, SocketCancellation);
         $p
     }
+
+    method listen(IO::Socket::Async:U: $host as Str, $port as Int,
+                  :$scheduler = $*SCHEDULER) {
+        my $s = Supply.new;
+        nqp::asynclisten(
+            $scheduler.queue,
+            -> Mu \socket, Mu \err {
+                if err {
+                    $s.quit(err);
+                }
+                else {
+                    my $client_socket := nqp::create(self);
+                    nqp::bindattr($client_socket, IO::Socket::Async, '$!VMIO', socket);
+                    $s.more($client_socket);
+                }
+            },
+            $host, $port, SocketCancellation);
+        $s
+    }
 }