Base
Number of bytes to receive at a time
Cleans up buffer and socket
# File lib/listen/adapter/tcp.rb, line 25 def finalize @buffer = nil if @socket @socket.close @socket = nil end end
Buffers incoming data and handles messages accordingly
# File lib/listen/adapter/tcp.rb, line 44 def handle_data(data) @buffer << data while (message = Listen::TCP::Message.from_buffer(@buffer)) handle_message(message) end end
Handles incoming message by notifying of path changes
# File lib/listen/adapter/tcp.rb, line 52 def handle_message(message) message.object.each do |change, paths| paths.each do |path| _notify_change(path, change: change.to_sym) end end end
Generated with the Darkfish Rdoc Generator 2.