1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
module NIO
# Monitors watch IO objects for specific events
class Monitor
attr_reader :io, :interests, :selector
attr_accessor :value, :readiness
# :nodoc
def initialize(io, interests, selector)
unless io.is_a?(IO)
if IO.respond_to? :try_convert
io = IO.try_convert(io)
elsif io.respond_to? :to_io
io = io.to_io
end
raise TypeError, "can't convert #{io.class} into IO" unless io.is_a? IO
end
@io, @interests, @selector = io, interests, selector
@closed = false
end
# Is the IO object readable?
def readable?
readiness == :r || readiness == :rw
end
# Is the IO object writable?
def writable?
readiness == :w || readiness == :rw
end
alias_method :writeable?, :writable?
# Is this monitor closed?
def closed?; @closed; end
# Deactivate this monitor
def close(deregister = true)
@closed = true
@selector.deregister(io) if deregister
end
end
end
|
