class ElasticAPM::Spies::MongoSpy::Subscriber

def pop_event(event)
  return unless (curr = ElasticAPM.current_span)
  span = @events.delete(event.operation_id)
  curr == span && ElasticAPM.end_span
end