#!/usr/bin/env php
<?php

require __DIR__ . '/../vendor/autoload.php';

use Amp\Pipeline\ConcurrentIterator;
use Amp\Pipeline\Pipeline;
use Amp\Pipeline\Queue;

class Wrapper implements \IteratorAggregate
{
    public function __construct(private readonly iterable $iterable)
    {
    }

    public function getIterator(): \Generator
    {
        yield from $this->iterable;
    }
}

$queue = new Queue();
$queue->pushAsync('foo');
$pipeline = Pipeline::fromIterable(new Wrapper($queue->iterate()));

function foo(ConcurrentIterator $iterator)
{
    $iterator->continue();

    return $iterator->getValue();
}

foo($pipeline->getIterator());

    public function testIssue88(): void
    {
        $subscription = $this->subscriber->subscribe('foo');
        delay(0.1); // Enter event loop so subscriber has time to connect.
        $subscription->unsubscribe();

        $subscription = $this->subscriber->subscribe('foo');

        async(fn () => $this->redis->publish('foo', 'bar'));

        $this->getNextValue(Pipeline::fromIterable($subscription)->getIterator());

        $receivedValue = $this->getNextValue(Pipeline::fromIterable($subscription)->getIterator());

        $this->assertSame('bar', $receivedValue);
    }