Method: Thin::DeferrableBody#each

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

#each(&blk) ⇒ Object 



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

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