@@ -47,7 +47,7 @@ function race(array $promisesOrValues)
4747 return resolve ();
4848 }
4949
50- $ cancellationQueue = new CancellationQueue ();
50+ $ cancellationQueue = new Internal \ CancellationQueue ();
5151
5252 return new Promise (function ($ resolve , $ reject ) use ($ promisesOrValues , $ cancellationQueue ) {
5353 foreach ($ promisesOrValues as $ promiseOrValue ) {
@@ -89,7 +89,7 @@ function some(array $promisesOrValues, $howMany)
8989 );
9090 }
9191
92- $ cancellationQueue = new CancellationQueue ();
92+ $ cancellationQueue = new Internal \ CancellationQueue ();
9393
9494 return new Promise (function ($ resolve , $ reject ) use ($ len , $ promisesOrValues , $ howMany , $ cancellationQueue ) {
9595 $ toResolve = $ howMany ;
@@ -136,7 +136,7 @@ function map(array $promisesOrValues, callable $mapFunc)
136136 return resolve ([]);
137137 }
138138
139- $ cancellationQueue = new CancellationQueue ();
139+ $ cancellationQueue = new Internal \ CancellationQueue ();
140140
141141 return new Promise (function ($ resolve , $ reject ) use ($ promisesOrValues , $ mapFunc , $ cancellationQueue ) {
142142 $ toResolve = count ($ promisesOrValues );
@@ -164,7 +164,7 @@ function ($mapped) use ($i, &$values, &$toResolve, $resolve) {
164164
165165function reduce (array $ promisesOrValues , callable $ reduceFunc , $ initialValue = null )
166166{
167- $ cancellationQueue = new CancellationQueue ();
167+ $ cancellationQueue = new Internal \ CancellationQueue ();
168168
169169 return new Promise (function ($ resolve , $ reject ) use ($ promisesOrValues , $ reduceFunc , $ initialValue , $ cancellationQueue ) {
170170 $ total = count ($ promisesOrValues );
0 commit comments