Method: Thin::DeferrableBody#each

Defined in:
lib/message_bus/rack/thin_ext.rb

#each(&blk) ⇒ Object 



20
21
22
23
 
# File 'lib/message_bus/rack/thin_ext.rb', line 20

def each(&blk)
  @body_callback = blk
  schedule_dequeue
end