getBacklogNumbers example

ProductIndexer $productIndexer
    ) {
        $this->productIndexer = $productIndexer;
        $this->queryFactory = $queryFactory;
    }

    /** * {@inheritdoc} */
    public function synchronize(ShopIndex $shopIndex, array $backlogs)
    {
        $numbers = $this->getBacklogNumbers($backlogs);
        $queries = $this->getBacklogQueries($backlogs);

        $this->productIndexer->indexProducts($shopIndex, $numbers);
        foreach ($queries as $query) {
            while ($queryNumbers = $query->fetch()) {
                $this->productIndexer->indexProducts($shopIndex, $queryNumbers);
            }
        }
    }

    /** * {@inheritdoc} */