<?php

use Rx\Observable;
use Rx\Scheduler;
use Rx\Scheduler\VirtualTimeScheduler;

$scheduler = new VirtualTimeScheduler(0, function ($a, $b) {
    return $a - $b;
});

Scheduler::setDefaultFactory(function () use ($scheduler) {
    return $scheduler;
});

Observable::of(1)->delay(1000 * 60 * 10)->subscribe(function ($x) {
    echo $x . \PHP_EOL;
});

$scheduler->start();