Class: Rack::Async::BlockingBody

Inherits:

Queue

• Object
• Queue
• Rack::Async::BlockingBody

Includes:

Deferrable

Defined in:

lib/rack/async.rb

Instance Method Summary

• #each ⇒ Object
• #initialize(*args) ⇒ BlockingBody constructor

  A new instance of BlockingBody.

• #set_deferred_status(*args) ⇒ Object

Methods included from Deferrable

#callback, #errback, #fail, #succeed

Constructor Details

#initialize(*args) ⇒ BlockingBody

# File 'lib/rack/async.rb', line 98

def initialize(*args)
  super
  @callbacks = []
  @errbacks = []
end

Instance Method Details

#each ⇒ Object

# File 'lib/rack/async.rb', line 104

def each
  until @deferred_status && empty?
    data = pop
    yield data if data
  end
rescue
  fail
  raise
end

#set_deferred_status(*args) ⇒ Object

# File 'lib/rack/async.rb', line 114

def set_deferred_status(*args)
  super
  self << nil
end