1 files changed, 50 insertions, 0 deletions
diff --git a/v_windows/v/vlib/net/unix/unix_test.v b/v_windows/v/vlib/net/unix/unix_test.v
new file mode 100644
index 0000000..cabcd52
--- /dev/null
+++ b/v_windows/v/vlib/net/unix/unix_test.v
@@ -0,0 +1,50 @@
+import os
+import net.unix
+
+const test_port = os.join_path(os.temp_dir(), 'unix_domain_socket')
+
+fn handle_conn(mut c unix.StreamConn) {
+	for {
+		mut buf := []byte{len: 100, init: 0}
+		read := c.read(mut buf) or {
+			println('Server: connection dropped')
+			return
+		}
+		c.write(buf[..read]) or {
+			println('Server: connection dropped')
+			return
+		}
+	}
+}
+
+fn echo_server(mut l unix.StreamListener) ? {
+	for {
+		mut new_conn := l.accept() or { continue }
+		go handle_conn(mut new_conn)
+	}
+}
+
+fn echo() ? {
+	mut c := unix.connect_stream(test_port) ?
+	defer {
+		c.close() or {}
+	}
+	data := 'Hello from vlib/net!'
+	c.write_string(data) ?
+	mut buf := []byte{len: 4096}
+	read := c.read(mut buf) ?
+	assert read == data.len
+	for i := 0; i < read; i++ {
+		assert buf[i] == data[i]
+	}
+	println('Got "$buf.bytestr()"')
+	return
+}
+
+fn test_tcp() {
+	assert os.exists(test_port) == false
+	mut l := unix.listen_stream(test_port) or { panic(err) }
+	go echo_server(mut l)
+	echo() or { panic(err) }
+	l.close() or {}
+}