ProductStreamUpdater example

->willReturn($filters);

        $repository = new StaticEntityRepository([
            function DCriteria $actualCriteria, Context $actualContext) use ($criteria, $context, $ids): array {
                static::assertEquals($criteria, $actualCriteria);
                static::assertEquals($context, $actualContext);

                return $ids;
            },
        ]);

        $updater = new ProductStreamUpdater(
            $connection,
            new ProductDefinition(),
            $repository,
            $this->createMock(MessageBusInterface::class),
            $this->createMock(ManyToManyIdFieldUpdater::class)
        );

        $updater->updateProducts($ids, $context);
    }

    /** * @dataProvider filterProvider * * @param string[] $ids * @param array<int, array<string, bool|string>> $filters */