danog/amp
1
0
Fork 0
mirror of https://github.com/danog/amp.git synced 2024-11-30 04:29:08 +01:00
Code Issues Projects Releases Wiki Activity

Resolve emit with observable result instead of emitting

Browse Source 
Emitting another observable will emit values from the emitted observable, then resolve the awaitable returned from emit with the observable result
This commit is contained in:
Aaron Piotrowski 2016-05-31 15:01:07 -05:00
parent a52e1e4c33
commit eb49e6e8ff
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
lib/Internal/Producer.php
View File

@ -106,13 +106,16 @@ trait Producer {
*/
private function push($value) {
try {
if ($value instanceof Awaitable) {
$value = (yield $value);
} elseif ($value instanceof Observable) {
if ($value instanceof Observable) {
$disposable = $value->subscribe(function ($value) {
return $this->emit($value);
});
$value = (yield $disposable);
yield Coroutine::result(yield $disposable);
return;
}
if ($value instanceof Awaitable) {
$value = (yield $value);
}
} catch (\Throwable $exception) {
if (!$this->resolved) {