about summary refs log tree commit homepage
path: root/lib/rainbows/rev/master.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/rainbows/rev/master.rb')
-rw-r--r--lib/rainbows/rev/master.rb23
1 files changed, 0 insertions, 23 deletions
diff --git a/lib/rainbows/rev/master.rb b/lib/rainbows/rev/master.rb
deleted file mode 100644
index 19992c2..0000000
--- a/lib/rainbows/rev/master.rb
+++ /dev/null
@@ -1,23 +0,0 @@
-# -*- encoding: binary -*-
-# :enddoc:
-require 'thread'
-class Rainbows::Rev::Master < Rev::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