<?php

declare(strict_types=1);

namespace Psl\Example\IO;

use Psl\Async;
use Psl\DateTime\Duration;
use Psl\IO;

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

Async\main(static function (): int {
    [$read, $write] = IO\pipe();

    Async\concurrently([
        static function () use ($read): void {
            IO\write_error_line('< sleeping.');

            Async\sleep(Duration::milliseconds(10));

            IO\write_error_line('< waiting for content.');

            $content = $read->readAll();

            IO\write_error_line('< received "%s".', $content);
            IO\write_error_line('< closing.');

            $read->close();
        },
        static function () use ($write): void {
            IO\write_error_line('> sleeping.');

            Async\sleep(Duration::milliseconds(100));

            IO\write_error_line('> writing.');

            $write->writeAll('hello, world');

            IO\write_error_line('> written "hello, world".');

            IO\write_error_line('> closing.');

            $write->close();
        },
    ]);

    return 0;
});