private function persistScheduled()
    {
        if ($this->shouldPersist()) {
            if (count($this->scheduledForInsertion)) {
                $this->objectPersister->insertMany($this->scheduledForInsertion);
                $this->scheduledForInsertion = [];
            }
            if (count($this->scheduledForUpdate)) {
                $this->objectPersister->replaceMany($this->scheduledForUpdate);
                $this->scheduledForUpdate = [];
            }
            if (count($this->scheduledForDeletion)) {
                $this->objectPersister->deleteManyByIdentifiers($this->scheduledForDeletion);
                $this->scheduledForDeletion = [];
            }
        }
    }
private function persistScheduled()
    {
        if ($this->shouldPersist()) {
            if (count($this->scheduledForInsertion)) {
                $this->objectPersister->insertMany($this->scheduledForInsertion);
                $this->scheduledForInsertion = [];
            }
            if (count($this->scheduledForUpdate)) {
                $this->objectPersister->replaceMany($this->scheduledForUpdate);
                $this->scheduledForUpdate = [];
            }
            if (count($this->scheduledForDeletion)) {
                $this->objectPersister->deleteManyByIdentifiers($this->scheduledForDeletion);
                $this->scheduledForDeletion = [];
            }
        }
    }
private function persistScheduled ( ) { if ( $ this -> shouldPersist ( ) ) { if ( count ( $ this -> scheduledForInsertion ) ) { $ this -> objectPersister -> insertMany ( $ this -> scheduledForInsertion ) ; $ this -> scheduledForInsertion = [ ] ; } if ( count ( $ this -> scheduledForUpdate ) ) { $ this -> objectPersister -> replaceMany ( $ this -> scheduledForUpdate ) ; $ this -> scheduledForUpdate = [ ] ; } if ( count ( $ this -> scheduledForDeletion ) ) { $ this -> objectPersister -> deleteManyByIdentifiers ( $ this -> scheduledForDeletion ) ; $ this -> scheduledForDeletion = [ ] ; } } }
Persist scheduled objects to ElasticSearch
After persisting, clear the scheduled queue to prevent multiple data updates when using multiple flush calls.
Persist scheduled objects to ElasticSearch After persisting clear the scheduled queue to prevent multiple data updates when using multiple flush calls .