>bRZ慰'r9B#̙Qu@~~W189%Jhxf';nzyoAn7QaTklхBͭELhyU;,EEabG=|;  h@v8[3';d-* Iw#a<F(f|U_Ae_By3~;"kH ;J؎58JV$J6WX=`{T?D'S^2Q$%)# z*$~|muo˽]:!q P3DW(Y=ꯍqsȴ" vuvA!_F#l71KۑD.)Bre7,V)2n,.CZ-w =Zlӌ(`X[MJK5%"+'N 2>rdcOI;eȻf|\MN,t&Zݐh6}O;eDULQ IyR ~;g;SgJ+: SYl wn.t,hM6غVUOE[ٖ frU͐Z2tS|ƳK=R0#츣%Pphr%E.J#j7`*qzxwᒊYcA z#?Aσ{M˱O `p .+NwpU֞ jth3u#T7@ ~K^e-O_; 7+ᐏ3Y-}R9Kn@/.ԇ(wqzͶ*7z0 a- @5 GL wŚ$aʨ iYrb-Jx (]Ő_ͺ*>(oӸKR0I.lD~r+b *g@o?}Q9N5vX})v.m`Z]7(7;f-D6~!uJ ]9{f;lF[Ĉn[9'@;ȸ59N()dELl©բȦ,°d&}c*~ W%w۲;`~Zϳ?073,-yUd  Q(3AsP8J mwBR%bA`C83F rnw{ϐ͓txm*1%X,= ъ ֢8Y=o%Dz8H Ƃ,1o=XrFOyWydm-![er2E#}:;K7=!/O܎pm8>ee2cD٥FR?\`=Po^L!H{@̾O*#UT4qu@#yfRtrICm?D$P y|e  g>ֲ$Z*?*:mɳp`~6EL|##K s"yMCI pba}y;¤-(xeȁf+ڶRX,aZKCoZN!VD4+hgV,"3Wdk | Ds `h@E+J#Ґ/fJpbX@ V̮ShW1m֔zRvt!fWWO0FE^S8bj,9vwl*Q#{Jӧۯ 81Go*ɿ\d-Rj)}jU_NWWu'-+r?I*0u` * (ƲڹZü%Fj׭kCc"j`)8O@M8##DHܨ{B'Y&ЊGŭ75mzbtKz%zߤE|Wi`#'-+r?`2d \/j/@@=2>@ ŽÀZ!LēJ2 x*2"A!=[f!lz[ M+2|)Q|hvP r*+^*Y0!ES yIadZU};Fx!/и'\,S362rr*A\_~?Ũ699+nت-fv4#9'3,r&#LX>lY۟ݎľ :=7$߮3j}AblmӀg5̺U5ݖ!yx_ThÓq8j*D "Ad•<ꂄE6p'!|p%#G~ѝOQ{ͪb zB${uO$Dd6C}ʡʸ.lCJaV)H~#}4~HL\ :^,(#C,bSվ4 VfVe.yՀ'kn%eF2|hŏE&ۆd) H-DhߦYC#,,*ந7{`RW÷ZU};Fx!>~)i~+i{rr*A\_~?A5 8L:knj1ť|vlÓ!4 4s {Lw[$5^F4 dA.>#1B7^LjC;}g[X-Ҝa|+eM4z}6TЂ5@f%Ȧ+oПp+_XTATݵr=K  @x>jn?F]vaۤbSw03CZ.7h٩LT2T :QV;K4R=ARջ|QϸnFK`&M?h69||iYvؽ |dL-K7c?0}\&_Tq'4&8hqex1+~=M55E*k\kz?Ĥb~kwr8;wJ * STjl+Eu6\Wr!w%tytk}v!A.>IcGʪA@sW.07٨p೴ v I&m)T,R[#ՅBj 42 = 9Lfɡ]wU;JAW \ x&!(W=OW{-e62_ݩĽ[KYtKgU3xQ썖¸Lrb-Jx (]Ő}ͣ'dkoXJZ;BpxBt = $this->waitFn = null; $this->cancelFn = null; if (!$handlers) { return; } // If the value was not a settled promise or a thenable, then resolve // it in the task queue using the correct ID. if (!is_object($value) || !method_exists($value, 'then')) { $id = $state === self::FULFILLED ? 1 : 2; // It's a success, so resolve the handlers in the queue. Utils::queue()->add(static function () use ($id, $value, $handlers): void { foreach ($handlers as $handler) { self::callHandler($id, $value, $handler); } }); } elseif ($value instanceof Promise && Is::pending($value)) { // We can just merge our handlers onto the next promise. $value->handlers = array_merge($value->handlers, $handlers); } else { // Resolve the handlers when the forwarded promise is resolved. $value->then( static function ($value) use ($handlers): void { foreach ($handlers as $handler) { self::callHandler(1, $value, $handler); } }, static function ($reason) use ($handlers): void { foreach ($handlers as $handler) { self::callHandler(2, $reason, $handler); } } ); } } /** * Call a stack of handlers using a specific callback index and value. * * @param int $index 1 (resolve) or 2 (reject). * @param mixed $value Value to pass to the callback. * @param array $handler Array of handler data (promise and callbacks). */ private static function callHandler(int $index, $value, array $handler): void { /** @var PromiseInterface $promise */ $promise = $handler[0]; // The promise may have been cancelled or resolved before placing // this thunk in the queue. if (Is::settled($promise)) { return; } try { if (isset($handler[$index])) { /* * If $f throws an exception, then $handler will be in the exception * stack trace. Since $handler contains a reference to the callable * itself we get a circular reference. We clear the $handler * here to avoid that memory leak. */ $f = $handler[$index]; unset($handler); $promise->resolve($f($value)); } elseif ($index === 1) { // Forward resolution values as-is. $promise->resolve($value); } else { // Forward rejections down the chain. $promise->reject($value); } } catch (\Throwable $reason) { $promise->reject($reason); } } private function waitIfPending(): void { if ($this->state !== self::PENDING) { return; } elseif ($this->waitFn) { $this->invokeWaitFn(); } elseif ($this->waitList) { $this->invokeWaitList(); } else { // If there's no wait function, then reject the promise. $this->reject('Cannot wait on a promise that has ' .'no internal wait function. You must provide a wait ' .'function when constructing the promise to be able to ' .'wait on a promise.'); } Utils::queue()->run(); /** @psalm-suppress RedundantCondition */ if ($this->state === self::PENDING) { $this->reject('Invoking the wait callback did not resolve the promise'); } } private function invokeWaitFn(): void { try { $wfn = $this->waitFn; $this->waitFn = null; $wfn(true); } catch (\Throwable $reason) { if ($this->state === self::PENDING) { // The promise has not been resolved yet, so reject the promise // with the exception. $this->reject($reason); } else { // The promise was already resolved, so there's a problem in // the application. throw $reason; } } } private function invokeWaitList(): void { $waitList = $this->waitList; $this->waitList = null; foreach ($waitList as $result) { do { $result->waitIfPending(); $result = $result->result; } while ($result instanceof Promise); if ($result instanceof PromiseInterface) { $result->wait(false); } } } }