danog/amp
1
0
Fork 0
mirror of https://github.com/danog/amp.git synced 2024-11-26 20:15:00 +01:00
Code Issues Projects Releases Wiki Activity

Fix line lengths

Browse Source
This commit is contained in:
Niklas Keller 2017-04-13 18:49:32 +02:00
parent 5e545301cd
commit fed09e42ac
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
lib/functions.php
View File

@ -27,8 +27,8 @@ namespace Amp {
/**
* Returns a new function that wraps $worker in a promise/coroutine-aware function that automatically upgrades
* Generators to coroutines. The returned function always returns a promise when invoked. If $worker throws, a failed
* promise is returned.
* Generators to coroutines. The returned function always returns a promise when invoked. If $worker throws,
* a failed promise is returned.
*
* @param callable (mixed ...$args): mixed $worker
*
@ -202,8 +202,8 @@ namespace Amp\Promise {
/**
* @param \Amp\Promise|\React\Promise\PromiseInterface $promise
* @param string $className Throwable class name to capture. Given callback will only be invoked if the failure reason
* is an instance of the given throwable class name.
* @param string $className Throwable class name to capture. Given callback will only be invoked if the failure
* reason is an instance of the given throwable class name.
* @param callable (\Throwable $exception): mixed $functor
*
* @return \Amp\Promise
@ -404,19 +404,19 @@ namespace Amp\Promise {
throw new UnionTypeError([Promise::class, ReactPromise::class], $promise);
}
$promise->onResolve(function ($exception, $value) use (&$deferred, &$exceptions, &$pending, &$resolved, $key) {
$promise->onResolve(function ($error, $value) use (&$deferred, &$exceptions, &$pending, &$resolved, $key) {
if ($pending === 0) {
return;
}
if (!$exception) {
if (!$error) {
$pending = 0;
$deferred->resolve($value);
$deferred = null;
return;
}
$exceptions[$key] = $exception;
$exceptions[$key] = $error;
if (0 === --$pending) {
$deferred->fail(new MultiReasonException($exceptions));
}
@ -500,8 +500,8 @@ namespace Amp\Stream {
use Amp\UnionTypeError;
/**
* Creates a stream from the given iterable, emitting the each value. The iterable may contain promises. If any promise
* fails, the stream will fail with the same reason.
* Creates a stream from the given iterable, emitting the each value. The iterable may contain promises. If any
* promise fails, the stream will fail with the same reason.
*
* @param array|\Traversable $iterable Elements to emit.
* @param int $delay Delay between element emissions.