Class: EStream::Chunked

Inherits:
Generic show all
Defined in:
lib/e-core/instance/stream.rb

Instance Method Summary collapse

Methods inherited from Generic

#callback, #closed?, defer, #each, #initialize, schedule

Constructor Details

This class inherits a constructor from EStream::Generic

Instance Method Details

#<<(data) ⇒ Object 



104
105
106
107
108
 
# File 'lib/e-core/instance/stream.rb', line 104

def << data
  data = data.to_s.chomp + "\n" # ensure data ends in a new line
  size = data.bytesize.to_s(16)
  super size + "\r\n" + data + "\r\n"
end

#close ⇒ Object 



110
111
112
113
 
# File 'lib/e-core/instance/stream.rb', line 110

def close
  @scheduler.schedule { @front.call("0\r\n\r\n") } unless closed?
  super
end