class ElasticAPM::Spies::MongoSpy::Subscriber

def push_event(event)
  return unless ElasticAPM.current_transaction
  span =
    ElasticAPM.start_span(
      event.command_name.to_s,
      TYPE,
      context: build_context(event)
    )
  @events[event.operation_id] = span
end