Method: Rack::App::Streamer#initialize

Defined in:
lib/rack/app/streamer.rb

#initialize(env, options = {}, &back) ⇒ Streamer

Returns a new instance of Streamer.



15
16
17
18
19
20
21
22
 
# File 'lib/rack/app/streamer.rb', line 15

def initialize(env, options={}, &back)
  @serializer = env[::Rack::App::Constants::ENV::SERIALIZER]
  @extname = env[::Rack::App::Constants::ENV::EXTNAME]
  @scheduler = options[:scheduler] || Rack::App::Streamer::Scheduler.by_env(env)
  @keep_open = options[:keep_open] || false
  @back = back.to_proc
  @callbacks, @closed = [], false
end