miquido/observable

<?php

declare(strict_types=1);

namespace Miquido\Observable\Operator;

use Miquido\Observable\ObservableInterface;
use Miquido\Observable\OperatorInterface;

final class Sum implements OperatorInterface
{
    public function process(ObservableInterface $source): ObservableInterface
    {
        return $source->pipe(new Reduce(function ($carry, $item) {
            return $carry + $item;
        }, 0));
    }
}