Merge pull request #24409 from ziglang/net

std.net: update to new I/O API

1 files changed, 8 insertions, 4 deletions

diff --git a/lib/std/net/test.zig b/lib/std/net/test.zig
index b94c038714..a7e6b465cb 100644
--- a/lib/std/net/test.zig
+++ b/lib/std/net/test.zig
@@ -208,7 +208,8 @@ test "listen on a port, send bytes, receive bytes" {
             const socket = try net.tcpConnectToAddress(server_address);
             defer socket.close();
 
-            _ = try socket.writer().writeAll("Hello world!");
+            var stream_writer = socket.writer(&.{});
+            try stream_writer.interface.writeAll("Hello world!");
         }
     };
 
@@ -218,7 +219,8 @@ test "listen on a port, send bytes, receive bytes" {
     var client = try server.accept();
     defer client.stream.close();
     var buf: [16]u8 = undefined;
-    const n = try client.stream.reader().read(&buf);
+    var stream_reader = client.stream.reader(&.{});
+    const n = try stream_reader.interface().readSliceShort(&buf);
 
     try testing.expectEqual(@as(usize, 12), n);
     try testing.expectEqualSlices(u8, "Hello world!", buf[0..n]);
@@ -299,7 +301,8 @@ test "listen on a unix socket, send bytes, receive bytes" {
             const socket = try net.connectUnixSocket(path);
             defer socket.close();
 
-            _ = try socket.writer().writeAll("Hello world!");
+            var stream_writer = socket.writer(&.{});
+            try stream_writer.interface.writeAll("Hello world!");
         }
     };
 
@@ -309,7 +312,8 @@ test "listen on a unix socket, send bytes, receive bytes" {
     var client = try server.accept();
     defer client.stream.close();
     var buf: [16]u8 = undefined;
-    const n = try client.stream.reader().read(&buf);
+    var stream_reader = client.stream.reader(&.{});
+    const n = try stream_reader.interface().readSliceShort(&buf);
 
     try testing.expectEqual(@as(usize, 12), n);
     try testing.expectEqualSlices(u8, "Hello world!", buf[0..n]);