[11.x] convert collect() helper to new Collection()

src/Illuminate/Broadcasting/Broadcasters/Broadcaster.php

@@ -10,6 +10,7 @@
 use Illuminate\Contracts\Routing\BindingRegistrar;
 use Illuminate\Contracts\Routing\UrlRoutable;
 use Illuminate\Support\Arr;
+use Illuminate\Support\Collection;
 use Illuminate\Support\Reflector;
 use ReflectionClass;
 use ReflectionFunction;
@@ -140,7 +141,7 @@ protected function extractAuthParameters($pattern, $channel, $callback)
     {
         $callbackParameters = $this->extractParameters($callback);
 
-        return collect($this->extractChannelKeys($pattern, $channel))->reject(function ($value, $key) {
+        return (new Collection($this->extractChannelKeys($pattern, $channel)))->reject(function ($value, $key) {
             return is_numeric($key);
         })->map(function ($value, $key) use ($callbackParameters) {
             return $this->resolveBinding($key, $value, $callbackParameters);
@@ -381,6 +382,6 @@ protected function channelNameMatchesPattern($channel, $pattern)
      */
     public function getChannels()
     {
-        return collect($this->channels);
+        return new Collection($this->channels);
     }
 }

src/Illuminate/Bus/Batch.php

@@ -205,7 +205,7 @@ public function add($jobs)
      */
     protected function prepareBatchedChain(array $chain)
     {
-        return collect($chain)->map(function ($job) {
+        return (new Collection($chain))->map(function ($job) {
             $job = $job instanceof Closure ? CallQueuedClosure::create($job) : $job;
 
             return $job->withBatchId($this->id);
@@ -245,7 +245,7 @@ public function recordSuccessfulJob(string $jobId)
         if ($this->hasProgressCallbacks()) {
             $batch = $this->fresh();
 
-            collect($this->options['progress'])->each(function ($handler) use ($batch) {
+            (new Collection($this->options['progress']))->each(function ($handler) use ($batch) {
                 $this->invokeHandlerCallback($handler, $batch);
             });
         }
@@ -257,15 +257,15 @@ public function recordSuccessfulJob(string $jobId)
         if ($counts->pendingJobs === 0 && $this->hasThenCallbacks()) {
             $batch = $this->fresh();
 
-            collect($this->options['then'])->each(function ($handler) use ($batch) {
+            (new Collection($this->options['then']))->each(function ($handler) use ($batch) {
                 $this->invokeHandlerCallback($handler, $batch);
             });
         }
 
         if ($counts->allJobsHaveRanExactlyOnce() && $this->hasFinallyCallbacks()) {
             $batch = $this->fresh();
 
-            collect($this->options['finally'])->each(function ($handler) use ($batch) {
+            (new Collection($this->options['finally']))->each(function ($handler) use ($batch) {
                 $this->invokeHandlerCallback($handler, $batch);
             });
         }
@@ -350,23 +350,23 @@ public function recordFailedJob(string $jobId, $e)
         if ($this->hasProgressCallbacks() && $this->allowsFailures()) {
             $batch = $this->fresh();
 
-            collect($this->options['progress'])->each(function ($handler) use ($batch, $e) {
+            (new Collection($this->options['progress']))->each(function ($handler) use ($batch, $e) {
                 $this->invokeHandlerCallback($handler, $batch, $e);
             });
         }
 
         if ($counts->failedJobs === 1 && $this->hasCatchCallbacks()) {
             $batch = $this->fresh();
 
-            collect($this->options['catch'])->each(function ($handler) use ($batch, $e) {
+            (new Collection($this->options['catch']))->each(function ($handler) use ($batch, $e) {
                 $this->invokeHandlerCallback($handler, $batch, $e);
             });
         }
 
         if ($counts->allJobsHaveRanExactlyOnce() && $this->hasFinallyCallbacks()) {
             $batch = $this->fresh();
 
-            collect($this->options['finally'])->each(function ($handler) use ($batch, $e) {
+            (new Collection($this->options['finally']))->each(function ($handler) use ($batch, $e) {
                 $this->invokeHandlerCallback($handler, $batch, $e);
             });
         }

src/Illuminate/Bus/Queueable.php

@@ -5,6 +5,7 @@
 use Closure;
 use Illuminate\Queue\CallQueuedClosure;
 use Illuminate\Support\Arr;
+use Illuminate\Support\Collection;
 use PHPUnit\Framework\Assert as PHPUnit;
 use RuntimeException;
 
@@ -203,7 +204,7 @@ public function through($middleware)
      */
     public function chain($chain)
     {
-        $jobs = ChainedBatch::prepareNestedBatches(collect($chain));
+        $jobs = ChainedBatch::prepareNestedBatches(new Collection($chain));
 
         $this->chained = $jobs->map(function ($job) {
             return $this->serializeJob($job);
@@ -220,7 +221,7 @@ public function chain($chain)
      */
     public function prependToChain($job)
     {
-        $jobs = ChainedBatch::prepareNestedBatches(collect([$job]));
+        $jobs = ChainedBatch::prepareNestedBatches(new Collection([$job]));
 
         $this->chained = Arr::prepend($this->chained, $this->serializeJob($jobs->first()));
 
@@ -235,7 +236,7 @@ public function prependToChain($job)
      */
     public function appendToChain($job)
     {
-        $jobs = ChainedBatch::prepareNestedBatches(collect([$job]));
+        $jobs = ChainedBatch::prepareNestedBatches(new Collection([$job]));
 
         $this->chained = array_merge($this->chained, [$this->serializeJob($jobs->first())]);
 
@@ -294,7 +295,7 @@ public function dispatchNextJobInChain()
      */
     public function invokeChainCatchCallbacks($e)
     {
-        collect($this->chainCatchCallbacks)->each(function ($callback) use ($e) {
+        (new Collection($this->chainCatchCallbacks))->each(function ($callback) use ($e) {
             $callback($e);
         });
     }
@@ -308,14 +309,14 @@ public function invokeChainCatchCallbacks($e)
     public function assertHasChain($expectedChain)
     {
         PHPUnit::assertTrue(
-            collect($expectedChain)->isNotEmpty(),
+            (new Collection($expectedChain))->isNotEmpty(),
             'The expected chain can not be empty.'
         );
 
-        if (collect($expectedChain)->contains(fn ($job) => is_object($job))) {
-            $expectedChain = collect($expectedChain)->map(fn ($job) => serialize($job))->all();
+        if ((new Collection($expectedChain))->contains(fn ($job) => is_object($job))) {
+            $expectedChain = (new Collection($expectedChain))->map(fn ($job) => serialize($job))->all();
         } else {
-            $chain = collect($this->chained)->map(fn ($job) => get_class(unserialize($job)))->all();
+            $chain = (new Collection($this->chained))->map(fn ($job) => get_class(unserialize($job)))->all();
         }
 
         PHPUnit::assertTrue(

src/Illuminate/Cache/Repository.php

@@ -21,6 +21,7 @@
 use Illuminate\Contracts\Cache\Store;
 use Illuminate\Contracts\Events\Dispatcher;
 use Illuminate\Support\Carbon;
+use Illuminate\Support\Collection;
 use Illuminate\Support\InteractsWithTime;
 use Illuminate\Support\Traits\Macroable;
 
@@ -141,11 +142,11 @@ public function many(array $keys)
     {
         $this->event(new RetrievingManyKeys($this->getName(), $keys));
 
-        $values = $this->store->many(collect($keys)->map(function ($value, $key) {
+        $values = $this->store->many((new Collection($keys))->map(function ($value, $key) {
             return is_string($key) ? $key : $value;
         })->values()->all());
 
-        return collect($values)->map(function ($value, $key) use ($keys) {
+        return (new Collection($values))->map(function ($value, $key) use ($keys) {
             return $this->handleManyResult($keys, $key, $value);
         })->all();
     }

src/Illuminate/Cache/RetrievesMultipleKeys.php

@@ -2,6 +2,8 @@
 
 namespace Illuminate\Cache;
 
+use Illuminate\Support\Collection;
+
 trait RetrievesMultipleKeys
 {
     /**
@@ -16,7 +18,7 @@ public function many(array $keys)
     {
         $return = [];
 
-        $keys = collect($keys)->mapWithKeys(function ($value, $key) {
+        $keys = (new Collection($keys))->mapWithKeys(function ($value, $key) {
             return [is_string($key) ? $key : $value => is_string($key) ? $value : null];
         })->all();
 

src/Illuminate/Collections/helpers.php

@@ -77,9 +77,9 @@ function data_get($target, $key, $default = null)
             $segment = match ($segment) {
                 '\*' => '*',
                 '\{first}' => '{first}',
-                '{first}' => array_key_first(is_array($target) ? $target : collect($target)->all()),
+                '{first}' => array_key_first(is_array($target) ? $target : (new Collection($target))->all()),
                 '\{last}' => '{last}',
-                '{last}' => array_key_last(is_array($target) ? $target : collect($target)->all()),
+                '{last}' => array_key_last(is_array($target) ? $target : (new Collection($target))->all()),
                 default => $segment,
             };
 

src/Illuminate/Concurrency/SyncDriver.php

@@ -5,6 +5,7 @@
 use Closure;
 use Illuminate\Contracts\Concurrency\Driver;
 use Illuminate\Support\Arr;
+use Illuminate\Support\Collection;
 use Illuminate\Support\Defer\DeferredCallback;
 
 use function Illuminate\Support\defer;
@@ -16,7 +17,7 @@ class SyncDriver implements Driver
      */
     public function run(Closure|array $tasks): array
     {
-        return collect(Arr::wrap($tasks))->map(
+        return (new Collection(Arr::wrap($tasks)))->map(
             fn ($task) => $task()
         )->all();
     }
@@ -26,6 +27,6 @@ public function run(Closure|array $tasks): array
      */
     public function defer(Closure|array $tasks): DeferredCallback
     {
-        return defer(fn () => collect(Arr::wrap($tasks))->each(fn ($task) => $task()));
+        return defer(fn () => (new Collection(Arr::wrap($tasks)))->each(fn ($task) => $task()));
     }
 }

src/Illuminate/Console/Concerns/CallsCommands.php

@@ -2,6 +2,7 @@
 
 namespace Illuminate\Console\Concerns;
 
+use Illuminate\Support\Collection;
 use Symfony\Component\Console\Input\ArrayInput;
 use Symfony\Component\Console\Output\NullOutput;
 use Symfony\Component\Console\Output\OutputInterface;
@@ -95,7 +96,7 @@ protected function createInputFromArguments(array $arguments)
      */
     protected function context()
     {
-        return collect($this->option())->only([
+        return (new Collection($this->option()))->only([
             'ansi',
             'no-ansi',
             'no-interaction',

src/Illuminate/Console/Concerns/InteractsWithSignals.php

@@ -4,6 +4,7 @@
 
 use Illuminate\Console\Signals;
 use Illuminate\Support\Arr;
+use Illuminate\Support\Collection;
 
 trait InteractsWithSignals
 {
@@ -30,7 +31,7 @@ public function trap($signals, $callback)
                 $this->getApplication()->getSignalRegistry(),
             );
 
-            collect(Arr::wrap(value($signals)))
+            (new Collection(Arr::wrap(value($signals))))
                 ->each(fn ($signal) => $this->signals->register($signal, $callback));
         });
     }

src/Illuminate/Console/GeneratorCommand.php

@@ -5,6 +5,7 @@
 use Illuminate\Console\Concerns\CreatesMatchingTest;
 use Illuminate\Contracts\Console\PromptsForMissingInput;
 use Illuminate\Filesystem\Filesystem;
+use Illuminate\Support\Collection;
 use Illuminate\Support\Str;
 use Symfony\Component\Console\Input\InputArgument;
 use Symfony\Component\Finder\Finder;
@@ -248,7 +249,7 @@ protected function possibleModels()
     {
         $modelPath = is_dir(app_path('Models')) ? app_path('Models') : app_path();
 
-        return collect(Finder::create()->files()->depth(0)->in($modelPath))
+        return (new Collection(Finder::create()->files()->depth(0)->in($modelPath)))
             ->map(fn ($file) => $file->getBasename('.php'))
             ->sort()
             ->values()
@@ -268,7 +269,7 @@ protected function possibleEvents()
             return [];
         }
 
-        return collect(Finder::create()->files()->depth(0)->in($eventPath))
+        return (new Collection(Finder::create()->files()->depth(0)->in($eventPath)))
             ->map(fn ($file) => $file->getBasename('.php'))
             ->sort()
             ->values()
@@ -460,7 +461,7 @@ protected function isReservedName($name)
     {
         return in_array(
             strtolower($name),
-            collect($this->reservedNames)
+            (new Collection($this->reservedNames))
                 ->transform(fn ($name) => strtolower($name))
                 ->all()
         );

src/Illuminate/Console/Scheduling/Schedule.php

@@ -14,6 +14,7 @@
 use Illuminate\Contracts\Queue\ShouldBeUnique;
 use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Queue\CallQueuedClosure;
+use Illuminate\Support\Collection;
 use Illuminate\Support\ProcessUtils;
 use Illuminate\Support\Traits\Macroable;
 use RuntimeException;
@@ -332,7 +333,7 @@ protected function mergePendingAttributes(Event $event)
      */
     protected function compileParameters(array $parameters)
     {
-        return collect($parameters)->map(function ($value, $key) {
+        return (new Collection($parameters))->map(function ($value, $key) {
             if (is_array($value)) {
                 return $this->compileArrayInput($key, $value);
             }
@@ -354,7 +355,7 @@ protected function compileParameters(array $parameters)
      */
     public function compileArrayInput($key, $value)
     {
-        $value = collect($value)->map(function ($value) {
+        $value = (new Collection($value))->map(function ($value) {
             return ProcessUtils::escapeArgument($value);
         });
 
@@ -391,7 +392,7 @@ public function serverShouldRun(Event $event, DateTimeInterface $time)
      */
     public function dueEvents($app)
     {
-        return collect($this->events)->filter->isDue($app);
+        return (new Collection($this->events))->filter->isDue($app);
     }
 
     /**

src/Illuminate/Console/Scheduling/ScheduleFinishCommand.php

@@ -5,6 +5,7 @@
 use Illuminate\Console\Command;
 use Illuminate\Console\Events\ScheduledBackgroundTaskFinished;
 use Illuminate\Contracts\Events\Dispatcher;
+use Illuminate\Support\Collection;
 use Symfony\Component\Console\Attribute\AsCommand;
 
 #[AsCommand(name: 'schedule:finish')]
@@ -39,7 +40,7 @@ class ScheduleFinishCommand extends Command
      */
     public function handle(Schedule $schedule)
     {
-        collect($schedule->events())->filter(function ($value) {
+        (new Collection($schedule->events()))->filter(function ($value) {
             return $value->mutexName() == $this->argument('id');
         })->each(function ($event) {
             $event->finish($this->laravel, $this->argument('code'));

src/Illuminate/Console/Scheduling/ScheduleListCommand.php

@@ -8,6 +8,7 @@
 use Illuminate\Console\Application;
 use Illuminate\Console\Command;
 use Illuminate\Support\Carbon;
+use Illuminate\Support\Collection;
 use ReflectionClass;
 use ReflectionFunction;
 use Symfony\Component\Console\Attribute\AsCommand;
@@ -50,7 +51,7 @@ class ScheduleListCommand extends Command
      */
     public function handle(Schedule $schedule)
     {
-        $events = collect($schedule->events());
+        $events = new Collection($schedule->events());
 
         if ($events->isEmpty()) {
             $this->components->info('No scheduled tasks have been defined.');
@@ -87,7 +88,7 @@ private function getCronExpressionSpacing($events)
     {
         $rows = $events->map(fn ($event) => array_map('mb_strlen', preg_split("/\s+/", $event->expression)));
 
-        return collect($rows[0] ?? [])->keys()->map(fn ($key) => $rows->max($key))->all();
+        return (new Collection($rows[0] ?? []))->keys()->map(fn ($key) => $rows->max($key))->all();
     }
 
     /**
@@ -244,7 +245,7 @@ private function formatCronExpression($expression, $spacing)
     {
         $expressions = preg_split("/\s+/", $expression);
 
-        return collect($spacing)
+        return (new Collection($spacing))
             ->map(fn ($length, $index) => str_pad($expressions[$index], $length))
             ->implode(' ');
     }