Implement .native-descriptor for async sockets

rakudo · Oct 19, 2018 · 865b1f3 · 865b1f3
1 parent a1a95e0
commit 865b1f3
Showing 1 changed file with 13 additions and 6 deletions.
diff --git a/src/core/IO/Socket/Async.pm6 b/src/core/IO/Socket/Async.pm6
@@ -122,7 +122,7 @@ my class IO::Socket::Async {
                     nqp::decont($!buf), SocketCancellation);
                 $tap := Tap.new({ nqp::cancel($cancellation) });
                 tap($tap);
-            };
+            }
 
             $!close-promise.then: {
                 $lock.protect: {
@@ -195,8 +195,8 @@ my class IO::Socket::Async {
                 if err {
                     $v.break: err;
                 } else {
-                    my \client = nqp::create(self);
-                    my $encoding      = Encoding::Registry.find($enc);
+                    my \client   = nqp::create(self);
+                    my $encoding = Encoding::Registry.find($enc);
                     nqp::bindattr(client, IO::Socket::Async, '$!VMIO', client-socket);
                     nqp::bindattr(client, IO::Socket::Async, '$!enc', $encoding.name);
                     nqp::bindattr(client, IO::Socket::Async, '$!encoder', $encoding.encoder());
@@ -219,9 +219,13 @@ my class IO::Socket::Async {
 
         submethod BUILD(Mu :$!VMIO, Promise :$!socket-host, Promise :$!socket-port) { }
 
-        method new(&on-close, Mu :$VMIO, Promise :$socket-host, Promise :$socket-port) {
+        method new(&on-close!, Mu :$VMIO!, Promise :$socket-host!, Promise :$socket-port!) {
             self.bless: :&on-close, :$VMIO, :$socket-host, :$socket-port;
         }
+
+        method native-descriptor(--> Int) {
+            nqp::filenofh(nqp::decont($!VMIO))
+        }
     }
 
     my class SocketListenerTappable does Tappable {
@@ -298,9 +302,8 @@ my class IO::Socket::Async {
 
                 CATCH {
                     default {
-                        $tap = ListenSocket.new({ Nil }, :$VMIO,
+                        tap($tap = ListenSocket.new: { Nil }, :$VMIO,
                             :$socket-host, :$socket-port) unless $tap;
-                        tap($tap);
                         quit($_);
                     }
                 }
@@ -327,6 +330,10 @@ my class IO::Socket::Async {
         nqp::bindattr(socket, IO::Socket::Async, '$!close-vow', $p.vow);
     }
 
+    method native-descriptor(--> Int) {
+        nqp::filenofh(nqp::decont($!VMIO))
+    }
+
 #?if moar
     method udp(IO::Socket::Async:U: :$broadcast, :$enc = 'utf-8', :$scheduler = $*SCHEDULER) {
         my $p = Promise.new;