PHP Decode

<?php

require_once __DIR__ . '/../bootstrap.php';

$loop      = React\EventLoop\Factory::create();
$scheduler = new Rx\Scheduler\EventLoopScheduler($loop);

$observable       = (new \Rx\Observable\ReturnObservable(42))->repeat();
$otherObservable  = (new \Rx\Observable\ReturnObservable(21))->repeat();
$mergedObservable = $observable->merge($otherObservable, $scheduler);

$disposable = $mergedObservable->subscribe($stdoutObserver, $scheduler);

$loop->addPeriodicTimer(0.01, function () {
    $memory    = memory_get_usage() / 1024;
    $formatted = number_format($memory, 3) . 'K';
    echo "Current memory usage: {$formatted}
";
});

$loop->run();


//Next value: 42
//Next value: 21
//Next value: 42
//Next value: 21
//Next value: 42
//Next value: 21
//Next value: 42
//Next value: 21
//Current memory usage: 838.547K
 ?>