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

Unsubscribe from emitted observable if failed

Browse Source
This commit is contained in:
Aaron Piotrowski 2016-08-16 16:31:09 -05:00
parent 84c2572e0a
commit 2317a3aa37
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib/Internal/Producer.php
View File

@ -81,7 +81,13 @@ trait Producer {
if ($value instanceof Awaitable) {
if ($value instanceof Observable) {
$value->subscribe(function ($value) {
$subscriber = $value->subscribe(function ($value) use (&$subscriber) {
/** @var \Amp\Subscriber $subscriber */
if ($this->resolved) {
$subscriber->unsubscribe();
return;
}
return $this->emit($value);
});