Module: Euston::Projections::MongoProjectionEventHandler::ClassMethods

Defined in:
lib/euston-projections/mongo_projection_event_handler.rb

Instance Method Summary collapse

Instance Method Details

#concurrent_subscribes(*args, &consumer) ⇒ Object 



11
12
13
14
15
16
17
 
# File 'lib/euston-projections/mongo_projection_event_handler.rb', line 11

def concurrent_subscribes *args, &consumer
  subscribes *args do |*block_args|
    detect_mongo_concurrency do
      instance_exec *block_args, &consumer
    end
  end
end