docs: def _start(self, request_id, docs):
          """Publish a CommandStartedEvent."""
          cmd = self.command.copy()
          cmd[self.field] = docs
          self.listeners.publish_command_start(
              cmd, self.db_name,
              request_id, self.sock_info.address, self.op_id)
          return cmd