*/ final class IterableStream implements ReadOnceResultStream, RequestStream { /** * @var iterable */ private $content; /** * @param iterable $content */ private function __construct(iterable $content) { $this->content = $content; } /** * @param self|iterable $content */ public static function create($content): IterableStream { if ($content instanceof self) { return $content; } if (is_iterable($content)) { return new self($content); } throw new InvalidArgument(\sprintf('Expect content to be an iterable. "%s" given.', \is_object($content) ? \get_class($content) : \gettype($content))); } public function length(): ?int { return null; } public function stringify(): string { if ($this->content instanceof \Traversable) { return implode('', iterator_to_array($this->content)); } return implode('', iterator_to_array((function () {yield from $this->content; })())); } public function getIterator(): \Traversable { yield from $this->content; } public function hash(string $algo = 'sha256', bool $raw = false): string { $ctx = hash_init($algo); foreach ($this->content as $chunk) { hash_update($ctx, $chunk); } return hash_final($ctx, $raw); } }