'Publish a CommandStartedEvent.'

def _start(self, request_id, docs):

    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
