Class: HttpStreamingClient::Decoders::Chunked

Inherits:
Object
  • Object
show all
Defined in:
lib/http_streaming_client/decoders/chunked.rb

Instance Method Summary collapse

Constructor Details

#initialize(&packet_callback) ⇒ Chunked

Returns a new instance of Chunked.



42
43
44
45
 
# File 'lib/http_streaming_client/decoders/chunked.rb', line 42

def initialize(&packet_callback)
	logger.debug "Chunked:initialize"
	@packet_callback = packet_callback
end

Instance Method Details

#<<(chunk) ⇒ Object 



47
48
49
50
51
52
53
54
55
 
# File 'lib/http_streaming_client/decoders/chunked.rb', line 47

def <<(chunk)
	return unless chunk && chunk.size > 0
	chunk_io = StringIO.new(chunk)
	while true
	  line = nonblock_readline(chunk_io)
	  break if line.nil?
	  process_line(line)
	end
end

#close ⇒ Object 



63
64
65
 
# File 'lib/http_streaming_client/decoders/chunked.rb', line 63

def close
	logger.debug "Chunked:close"
end

#logger ⇒ Object 



38
39
40
 
# File 'lib/http_streaming_client/decoders/chunked.rb', line 38

def logger
	HttpStreamingClient.logger
end

#size ⇒ Object 



57
58
59
60
61
 
# File 'lib/http_streaming_client/decoders/chunked.rb', line 57

def size
	logger.debug "Chunked:size"
	return @line_buffer.size unless @line_buffer.nil?
	return 0
end