Class: Rack::Async::BlockingBody

Inherits:

Queue

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

Defined in:

lib/rack/async.rb

Instance Method Summary

• #each ⇒ Object
• #succeed ⇒ Object (also: #finish, #fail)

Instance Method Details

#each ⇒ Object

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

def each
  until @finished && empty?
    data = pop
    yield data if data
  end
end

#succeed ⇒ Object Also known as: finish, fail

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

def succeed
  @finished = true
  self << nil
end