Method: Fleck::Core::Consumer::Base::ClassMethods#terminate

Defined in:
lib/fleck/core/consumer/base.rb

#terminate ⇒ Object 



44
45
46
47
 
# File 'lib/fleck/core/consumer/base.rb', line 44

def terminate
  consumers.each(&:terminate)
  lock.synchronize { condition.signal }
end