complete Rev => Coolio renaming

We use Cool.io internally everywhere now, but preserve
Rev-based models for anybody using them.

1 files changed, 23 insertions, 0 deletions

diff --git a/lib/rainbows/coolio/master.rb b/lib/rainbows/coolio/master.rb
new file mode 100644
index 0000000..4877e8e
--- /dev/null
+++ b/lib/rainbows/coolio/master.rb
@@ -0,0 +1,23 @@
+# -*- encoding: binary -*-
+# :enddoc:
+require 'thread'
+class Rainbows::Coolio::Master < Coolio::IOWatcher
+
+  def initialize(queue)
+    @reader, @writer = Kgio::Pipe.new
+    super(@reader)
+    @queue = queue
+  end
+
+  def <<(output)
+    @queue << output
+    @writer.kgio_trywrite("\0")
+  end
+
+  def on_readable
+    if String === @reader.kgio_tryread(1)
+      client, response = @queue.pop
+      client.response_write(response)
+    end
+  end
+end