[examples/echo.c3] inline client() function as lambda

Author: rexim

examples/echo.c3

@@ -4,34 +4,6 @@ import std::io;
 import std::net;
 import coroutine;
 
-fn void client(void *arg) {
-    io::printfn("[%d] Client connected!", coroutine::id());
-
-    TcpSocket* client_sock = (TcpSocket*)arg;
-    char[] buf = mem::new_array(char, 1024);
-    defer {
-        client_sock.close()!!;
-        free(client_sock);
-        free(buf.ptr);
-    }
-
-    while OUTER: (true) {
-        coroutine::sleep_read(client_sock.sock);
-        usz n = client_sock.read(buf)!!;
-        if (n == 0) break OUTER;
-        char[] chunk = buf[0:n];
-        io::printfn("[%d] Client sent %d bytes", coroutine::id(), chunk.len);
-
-        while (chunk.len > 0) {
-            coroutine::sleep_write(client_sock.sock);
-            usz m = client_sock.write(chunk)!!;
-            if (m == 0) break OUTER;
-            chunk = chunk[m..];
-        }
-    }
-    io::printfn("[%d] Client disconnected", coroutine::id());
-}
-
 fn void main() {
     coroutine::init();
 
@@ -45,6 +17,32 @@ fn void main() {
         coroutine::sleep_read(server_sock.sock);
         TcpSocket client_sock = tcp::accept(&server_sock)!!;
         client_sock.sock.set_non_blocking(true)!!;
-        coroutine::go(&client, @clone(client_sock));
+        coroutine::go(fn void(void *arg) {
+            io::printfn("[%d] Client connected!", coroutine::id());
+
+            TcpSocket* client_sock = (TcpSocket*)arg;
+            char[] buf = mem::new_array(char, 1024);
+            defer {
+                client_sock.close()!!;
+                free(client_sock);
+                free(buf.ptr);
+            }
+
+            while OUTER: (true) {
+                coroutine::sleep_read(client_sock.sock);
+                usz n = client_sock.read(buf)!!;
+                if (n == 0) break OUTER;
+                char[] chunk = buf[0:n];
+                io::printfn("[%d] Client sent %d bytes", coroutine::id(), chunk.len);
+
+                while (chunk.len > 0) {
+                    coroutine::sleep_write(client_sock.sock);
+                    usz m = client_sock.write(chunk)!!;
+                    if (m == 0) break OUTER;
+                    chunk = chunk[m..];
+                }
+            }
+            io::printfn("[%d] Client disconnected", coroutine::id());
+        }, @clone(client_sock));
     }
 }