Contents

# -*- encoding: binary -*-
# :enddoc:
module Rainbows::Fiber::Coolio::Methods
  class Watcher < Coolio::IOWatcher
    def initialize(fio, flag)
      @f = Fiber.current
      super(fio, flag)
      attach(Coolio::Loop.default)
    end

    def on_readable
      @f.resume
    end

    alias on_writable on_readable
  end

  def close
    @w.detach if defined?(@w) && @w.attached?
    @r.detach if defined?(@r) && @r.attached?
    super
  end

  def kgio_wait_writable
    @w = Watcher.new(self, :w) unless defined?(@w)
    @w.enable unless @w.enabled?
    Fiber.yield
    @w.disable
  end

  def kgio_wait_readable(timeout = nil)
    @r = Watcher.new(self, :r) unless defined?(@r)
    @r.enable unless @r.enabled?
    Fiber.yield
    @r.disable
  end
end

[
  Rainbows::Fiber::IO,
  # the next two trigger autoload, ugh, oh well...
  Rainbows::Fiber::IO::Socket,
  Rainbows::Fiber::IO::Pipe
].each do |klass|
  klass.__send__(:include, Rainbows::Fiber::Coolio::Methods)
end

Version data entries

21 entries across 21 versions & 1 rubygems

Version	Path
rainbows-5.2.1	lib/rainbows/fiber/coolio/methods.rb
rainbows-5.2.0	lib/rainbows/fiber/coolio/methods.rb
rainbows-5.1.1	lib/rainbows/fiber/coolio/methods.rb
rainbows-5.1.0	lib/rainbows/fiber/coolio/methods.rb
rainbows-5.0.0.5.ge717	lib/rainbows/fiber/coolio/methods.rb
rainbows-5.0.0	lib/rainbows/fiber/coolio/methods.rb
rainbows-4.7.0	lib/rainbows/fiber/coolio/methods.rb
rainbows-4.6.2	lib/rainbows/fiber/coolio/methods.rb
rainbows-4.6.1	lib/rainbows/fiber/coolio/methods.rb
rainbows-4.6.0.4.g4108	lib/rainbows/fiber/coolio/methods.rb
rainbows-4.6.0	lib/rainbows/fiber/coolio/methods.rb
rainbows-4.5.0	lib/rainbows/fiber/coolio/methods.rb
rainbows-4.4.3	lib/rainbows/fiber/coolio/methods.rb
rainbows-4.4.2	lib/rainbows/fiber/coolio/methods.rb
rainbows-4.4.1.1.gd5c8c	lib/rainbows/fiber/coolio/methods.rb
rainbows-4.4.1	lib/rainbows/fiber/coolio/methods.rb
rainbows-4.4.0	lib/rainbows/fiber/coolio/methods.rb
rainbows-4.3.1	lib/rainbows/fiber/coolio/methods.rb
rainbows-4.3.0	lib/rainbows/fiber/coolio/methods.rb
rainbows-4.2.0	lib/rainbows/fiber/coolio/methods.rb