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