Class: InternetHakai::RWatcher

Inherits:
Rev::IOWatcher
  • Object
show all
Extended by:
Rev::Meta
Defined in:
lib/internethakai/hakairev/revpipe.rb

Instance Method Summary collapse

Constructor Details

#initialize(r) ⇒ RWatcher

Returns a new instance of RWatcher.



24
25
26
27
 
# File 'lib/internethakai/hakairev/revpipe.rb', line 24

def initialize r
    @reader = r
    super(r)
end

Instance Method Details

#on_read(data) ⇒ Object 



28
 
# File 'lib/internethakai/hakairev/revpipe.rb', line 28

def on_read(data); end

#on_readable ⇒ Object 



30
31
32
33
34
35
36
37
 
# File 'lib/internethakai/hakairev/revpipe.rb', line 30

def on_readable
    begin
        on_read(@reader.read_nonblock(Rev::IO::INPUT_SIZE))
    rescue Errno::EAGAIN
        # in case there are spurious wakeups from forked processs
        return
    end
end