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

反应式扩展 - 将项目从一个集合泵送到另一个集合

发布于 2024-10-10 11:28:51 字数 81 浏览 2 评论 0原文

我有一个 IEnumerable 集合，并希望以一秒的间隔将项目泵入另一个集合。我该如何实现这一目标？有很多新的扩展方法。我还不知道在哪里使用什么。

原文

分享到QQ

分享到微博

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

发布评论

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

七秒鱼° 2024-10-17 11:28:52

这是您可以做到的一种方法。请注意，我并不是说这是最“Rx”的方式（我对 Rx 的经验仍然有限）。

public static IEnumerable<T> Delay(this IEnumerable<T> source, int interval)
{
    foreach (T item in source)
    {
        Thread.Sleep(interval);
        yield return item;
    }
}

进而：

var source = firstCollection.Delay(1000).ToObservable();
source.Subscribe(x => secondCollection.Add(x));

Here's one way you could do it. I'm not saying it's the most "Rx" way, mind you (my experience with Rx is still somewhat limited).

public static IEnumerable<T> Delay(this IEnumerable<T> source, int interval)
{
    foreach (T item in source)
    {
        Thread.Sleep(interval);
        yield return item;
    }
}

And then:

var source = firstCollection.Delay(1000).ToObservable();
source.Subscribe(x => secondCollection.Add(x));

回复收藏 0 原文

横笛休吹塞上声 2024-10-17 11:28:51

list1.ToObservable() // Convert list1 to Observable
    .Zip(
        Observable.Interval(TimeSpan.FromSeconds(1)), // Zip it with an observable that ticks every second
        (list, timerList) => list // select list1 only
    ).
Subscribe((item) =>
{
    list2.Add(item); // on each tick, add an item to list2
});

list1.ToObservable() // Convert list1 to Observable
    .Zip(
        Observable.Interval(TimeSpan.FromSeconds(1)), // Zip it with an observable that ticks every second
        (list, timerList) => list // select list1 only
    ).
Subscribe((item) =>
{
    list2.Add(item); // on each tick, add an item to list2
});

回复收藏 0 原文

~没有更多了~