AssignedToStreamCondition example

        if (!$streamId) {
            return [];
        }
        $stream = $this->manager->find(CustomerStreamEntity::class, $streamId);
        if (!$stream instanceof CustomerStreamEntity) {
            return [];
        }

        if ($stream->isStatic() || $stream->getFreezeUp()) {
            return [new AssignedToStreamCondition($streamId)];
        }

        return $this->reflectionHelper->unserialize(
            json_decode($stream->getConditions() ?? '', true),
            'Serialization error in Customer Stream'
        );
    }

    private function insertCustomers(array $customerIds, int $streamId): void
    {
        $connection = $this->connection;