writer_thread_*: split out common socket_proxy code

Needless duplication sucks

1 files changed, 24 insertions, 0 deletions

diff --git a/lib/rainbows/socket_proxy.rb b/lib/rainbows/socket_proxy.rb
new file mode 100644
index 0000000..e4cb686
--- /dev/null
+++ b/lib/rainbows/socket_proxy.rb
@@ -0,0 +1,24 @@
+# -*- encoding: binary -*-
+# :enddoc:
+#
+module Rainbows::SocketProxy
+  def kgio_addr
+    to_io.kgio_addr
+  end
+
+  def kgio_read(size, buf = "")
+    to_io.kgio_read(size, buf)
+  end
+
+  def kgio_read!(size, buf = "")
+    to_io.kgio_read!(size, buf)
+  end
+
+  def kgio_trywrite(buf)
+    to_io.kgio_trywrite(buf)
+  end
+
+  def timed_read(buf)
+    to_io.timed_read(buf)
+  end
+end