当前位置：文江博客话题详情

寻找一种优雅的方式从 IEnumerable 加载消息

发布于 2024-11-28 23:21:34 字数 182 浏览 1 评论 0原文

我的要求是在 x 秒间隔后循环 IEnumerable 集合中的消息。实际上我有一个 IEnumerable，它有 5 条消息，当屏幕（WPF）加载时，我显示集合中的第一条消息，下一条消息将在 x 秒后显示，所以在。

我想到的一种解决方案是使用调度程序计时器。还有其他方法可以做同样的事情吗？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

傲娇萝莉攻 2024-12-05 23:21:34

AFAIK 计时器正是为此目的而设计的，并且在其中表现良好。
为什么还要别的东西？

回复收藏 0 原文

菊凝晚露 2024-12-05 23:21:34

您可以使用反应式扩展来执行此操作。像这样的东西：

messages.ToObservable().Delay(new Timespan(0,0,x)).ObserveOn(Dispatcher)
.Subscribe(m => ShowMessage(m));

You can use reactive extensions to do this. Something like:

messages.ToObservable().Delay(new Timespan(0,0,x)).ObserveOn(Dispatcher)
.Subscribe(m => ShowMessage(m));

回复收藏 0 原文

小ぇ时光︴ 2024-12-05 23:21:34

这个答案与 Ankur 的思路一致——使用 Reactive 扩展生成基于计时器的可观察序列：

public ObservableCollection<Message> Messages { get; set; }

void QueueMessages(IEnumerable<Message> messages)
{
    int intervalSeconds = 5;

    // generate the observable source
    var enumerator = messages.GetEnumerator();
    var source = Observable.Generate(
            enumerator,                                  // initial value
            i => enumerator.MoveNext(),                  // condition
            i => i,                                      // iterate
            i => enumerator.Current,                     // selector
            i => TimeSpan.FromSeconds(intervalSeconds))  // interval selector
        .ObserveOnDispatcher();

    // subscribe to the source
    source.Subscribe(

        // display messages as they arrive
        message => Messages.Add(message),

        // add a "complete" message when done
        () => Messages.Add(new Message("complete!"))
    );
}

当然，效果与 DispatcherTimer 相同，但这里的语法更清晰，可以在每个计时器滴答时枚举一次。

This answer is along the lines of Ankur's -- use Reactive extensions to generate a timer-based observable sequence:

public ObservableCollection<Message> Messages { get; set; }

void QueueMessages(IEnumerable<Message> messages)
{
    int intervalSeconds = 5;

    // generate the observable source
    var enumerator = messages.GetEnumerator();
    var source = Observable.Generate(
            enumerator,                                  // initial value
            i => enumerator.MoveNext(),                  // condition
            i => i,                                      // iterate
            i => enumerator.Current,                     // selector
            i => TimeSpan.FromSeconds(intervalSeconds))  // interval selector
        .ObserveOnDispatcher();

    // subscribe to the source
    source.Subscribe(

        // display messages as they arrive
        message => Messages.Add(message),

        // add a "complete" message when done
        () => Messages.Add(new Message("complete!"))
    );
}

Of course, the effect is the same as a DispatcherTimer, but the syntax here is cleaner for enumerating once on each timer tick.

回复收藏 0 原文

~没有更多了~