Sha256: bd6bb345a719b55ebfc7660ced83769e737a037c5981cd174da5fe73d5d183c9
Contents?: true
Size: 1.18 KB
Versions: 63
Compression:
Stored size: 1.18 KB
Contents
module KQueue
class Watcher
# The {Watcher} subclass for events
# fired when a stream can be read from or written to
# (which of these is determined by \{#type}).
# Read events are watched via {Queue#watch_stream_for_read},
# and write events are watched via {Queue#watch_stream_for_write}.
#
# Note that read and write events for sockets
# use the {SocketReadWrite} class.
class ReadWrite < Watcher
# The Ruby IO object from which the file descriptor was extracted.
# This is only set if an IO object was used to construct this watcher.
# Otherwise, it's `nil`.
#
# @return [IO, nil]
attr_reader :io
# The file descriptor for the stream being watched.
#
# @return [Fixnum]
attr_reader :fd
# The type of watcher, `:read` or `:write`.
#
# @return [Symbol]
attr_reader :type
# Creates a new read/write Watcher.
#
# @private
def initialize(queue, fd, type, callback)
if fd.is_a?(IO)
@io = fd
fd = fd.fileno
end
@fd = fd
@type = type
super(queue, @fd, type, [], nil, callback)
end
end
end
end
Version data entries
63 entries across 55 versions & 8 rubygems