Sync/SyncStorageImportIterator.php
public function next()
    {
        $this->currentChunk = $this->syncStorage->getChunk(1, $this->documentType, $this->shopId);

        if (empty($this->currentChunk)) {
            $this->valid = false;

            return;
        }

        $this->currentEntity = $this
            ->entityManager
            ->getRepository($this->entityClass)->find($this->currentChunk[0]['document_id']);

        if (!empty($this->currentEntity) || $this->currentChunk[0]['type'] == ActionTypes::DELETE) {
            $this->valid = true;

            return;
        }

        $this->valid = false;
    }
public function next()
    {
        $this->currentChunk = $this->syncStorage->getChunk(1, $this->documentType, $this->shopId);

        if (empty($this->currentChunk)) {
            $this->valid = false;

            return;
        }

        $this->currentEntity = $this
            ->entityManager
            ->getRepository($this->entityClass)->find($this->currentChunk[0]['document_id']);

        if (!empty($this->currentEntity) || $this->currentChunk[0]['type'] == ActionTypes::DELETE) {
            $this->valid = true;

            return;
        }

        $this->valid = false;
    }
{@inheritdoc}