$source * @return ConcurrentIterator */ public function __invoke(ConcurrentIterator $source): ConcurrentIterator { $values = \iterator_to_array($source, false); \usort($values, $this->compare); return new ConcurrentArrayIterator($values); } }