# File lib/iproto/em.rb, line 8 def post_init raise "you should set @_needed_size" unless @_needed_size end
# File lib/iproto/em.rb, line 26 def receive_chunk(chunk) # for override end
# File lib/iproto/em.rb, line 12 def receive_data(data) @buffer ||= '' offset = 0 while (chunk = data[offset, _needed_size - @buffer.size]).size > 0 @buffer << chunk offset += chunk.size if @buffer.size == _needed_size chunk = @buffer @buffer = '' receive_chunk chunk end end end
Generated with the Darkfish Rdoc Generator 2.