# File lib/rb-kqueue/queue.rb, line 88 def watch_stream_for_read(fd, &callback) Watcher::ReadWrite.new(self, fd, :read, callback) end