如何防止枚举器聚合所有项目？

Question

我有一个简单的函数，在这里我只是用作示例。这是一个无限的枚举！

public static IEnumerable<int> Roll()
{
    while (true)
    {
        yield return new Random().Next(1, 6);
    }
}

我希望这个函数在特定数量的时钟滴答声中保持滚动，所以我有这个方法：

    public static List<T> Ticks<T>(this IEnumerable<T> data, int time)
    {
        var list = new List<T>();
        Stopwatch timer = null;
        foreach (var item in data)
        {
            if (timer == null)
            {
                timer = Stopwatch.StartNew();
            }

            if (timer.ElapsedTicks < time)
            {
                list.Add(item);
            }
            else
            {
                break;
            }
        }
        timer?.Stop();
        return list;
    }

但我不太喜欢这样写，因为我更喜欢这样的东西：

    public static List<T> Ticks2<T>(this IEnumerable<T> data, int time)
    {
        var list = new List<T>();
        Stopwatch timer = Stopwatch.StartNew();
        using (var en = data.GetEnumerator())
        {
            while (timer.ElapsedTicks < time && en.MoveNext())
            {
                list.Add(en.Current);
            }
        }
        timer.Stop();
        return list;
    }

但后一个函数将失败，因为 GetEnumerator() 方法将聚合所有数据并以不定式枚举的形式进行，这需要很长时间...
等等...我错了...转了太快了，以至于我的列表内存不足...幸运的是，它没有汇总...
Ticks() 方法工作正常，顺便说一句！我可以用这个：

Console.WriteLine( Watch.Roll().Ticks(10000).AllToString().AllJoin(", ") );

它将一直滚动到 10,000 个滴答声过去，将所有内容转换为字符串并加入所有内容，同时保留方法链。这很重要，顺便说一句。我不能接受任何会破坏方法链的答案。请记住，这只是一个示例。
不，我不能对 Roll() 方法进行任何更改。那个方法是只读的……

那么，我怎样才能将这个 Ticks() 方法重写为更类似于 Ticks2() 方法而不最终聚合所有数据？

---

对于那些对 AllToString() 和 AllJoin 方法感兴趣的人：

    public static IEnumerable<string> AllToString<T>(this IEnumerable<T> data) => data.Select(item => item.ToString());
    public static string AllJoin<T>(this IEnumerable<T> data, string separator) => string.Join(separator, data.AllToString());

这两种方法对于您将使用枚举并希望输出字符串的其他解决方案非常实用。

Answer 1

public static IEnumerable<T> Ticks<T>( this IEnumerable<T> source, Int64 totalTicks )
{
    Stopwatch sw = Stopwatch.StartNew();

    foreach( T item in source )
    {
        if( sw.ElapsedTicks < totalTicks )
        {
            yield return item;
        }
        else
        {
            yield break;
        }
    }
}

您实际上根本不需要任何自定义扩展方法：您也可以只使用TakeWhile 代替Ticks、Select 代替AllToString() 和Aggregate 代替AllJoin：

Stopwatch sw = Stopwatch.StartNew();

String all = Watch.Roll()
    .TakeWhile( _ => sw.ElapsedTicks < 10000 )
    .Select( i => i.ToString() )
    .Aggregate(
        new StringBuilder(),
        ( s, sb ) => sb.Append( s ).Append(", "),
        sb => sb.ToString()
    );

Console.WriteLine( all ):