Test not working about rxphp

[mbonneau]

I suspect the issue you are having has to do with the scheduler. This library generally works asynchronously, so the Observable::of(42) just schedules the emission of a value and does not emit a value unit the underlying scheduler is run. This means the then callable does not get called until after your assertion is made (again, assuming the scheduler is started at some point).

If you wanted it to work immediately, you can use the ImmediateScheduler:

<?php

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

$promise = \Rx\Observable::of(42, new \Rx\Scheduler\ImmediateScheduler())->toPromise();

$result = null;

$promise->then(function ($value) use (&$result) {
    $result = $value;
});

echo $result . PHP_EOL;

This can also be set with the global configuration:

\Rx\Scheduler::setDefaultFactory(function () {
    return new \Rx\Scheduler\ImmediateScheduler();
});

$promise = \Rx\Observable::of(42)->toPromise();

Or, if you are intending to be async, you could defer checking the result until the after the value is emitted.

[mbonneau]

@mpjraaij I just saw your comment on https://github.com/voryx/PgAsync. If you are using this in conjunction with that, you do not want to use the ImmediateScheduler.