(self, request_id, docs)
return cmd
Publish a CommandStartedEvent.
Publish a CommandStartedEvent.
Publish a CommandStartedEvent .
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
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