Implement IOStream

CHANGELOG.md

@@ -10,7 +10,7 @@
 - Implement `IO.copy_stream`
 - Add `Fiber#value` as alias to `Fiber#await`
 - Implement fiber-aware `Monitor` class (#113)
-- Implement Thread#value
+- Implement `Thread#value`
 
 ## 1.5 2023-07-28
 

Rakefile

@@ -2,18 +2,21 @@
 
 require "bundler/gem_tasks"
 require "rake/clean"
-
+require "rake/testtask"
 require "rake/extensiontask"
+
 Rake::ExtensionTask.new("polyphony_ext") do |ext|
   ext.ext_dir = "ext/polyphony"
 end
 
 task :recompile => [:clean, :compile]
 task :default => [:compile, :test]
 
-task :test do
-  exec 'ruby test/run.rb'
-end
+test_config = -> (t) {
+  t.libs << "test"
+  t.test_files = FileList["test/**/test_*.rb"]
+}
+Rake::TestTask.new(test: :compile, &test_config)
 
 task :stress_test do
   exec 'ruby test/stress.rb'

examples/pipes/http_server2.rb

@@ -28,7 +28,7 @@ def handle_client(conn)
         parser << msg
         break if done
       end
-  
+
       conn << "HTTP/1.1 200 OK\r\nContent-Length: 14\r\n\r\nHello, world!\n"
       done = false
       headers = nil

ext/polyphony/backend_common.h

@@ -166,4 +166,4 @@ void backend_setup_stats_symbols();
 int backend_getaddrinfo(VALUE host, VALUE port, struct sockaddr **ai_addr);
 VALUE name_to_addrinfo(void *name, socklen_t len);
 
-#endif /* BACKEND_COMMON_H */
+#endif /* BACKEND_COMMON_H */