1

我正在阅读 Rx 并通过一些示例。我正在尝试实现这一点：

List<A> LIstA {get;set;}
List<B> LIstB {get;set;}
List<C> LIstC {get;set;}

private void GetItems()
{
    ListA = GetItemsA();
    ListB = GetItemsB();
    ListC = GetItemsC();
}

所有这些代码都在主线程上执行。我删除了主线程 (UI) 使用此列表的代码。我想要的是以异步方式获取这些项目，但我需要以预定义的顺序获取结果。

以异步方式运行它没有问题，但我在以预定义的顺序获取结果时遇到问题。因此，我运行代码，显示 UI，几秒钟后ListA填充，然后ListB，最后ListC，仅以这个预定义的顺序。

如何做到这一点？

4

4 回答 4

1

Task或者async可能比 Rx 更适合这个模型。

尽管如此，根据我对您的问题的推断，在前一个完成后使用 concat 连接一个 observable：

        Func<Action, IObservable<Unit>> fetch = 
            action => Observable.Defer(() => Observable.Start(action));

        fetch(() => A())
        .Concat(fetch(() => B()))
        .Concat(fetch(() => C()))
        .Subscribe();
于 2012-09-23T13:09:24.770 回答
0

这对你有用吗？

GetItemsA().ToObservable()
    .Zip(GetItemsB().ToObservable(), (a, b) => new { a, b, })
    .Zip(GetItemsC().ToObservable(), (ab, c) => new { ab.a, ab.b, c, })
    .Subscribe(abc =>
    {
        ListA = abc.a;
        ListB = abc.b;
        ListC = abc.c;
    });
于 2012-09-24T00:27:40.750 回答
0

根据您的问题，您有三个不同类型的集合。显然，一个人不能连接三个不同类型的流。我认为@Enigmativity's 是最正确的，但为了使其工作，您需要将其更改为：

var uiScheduler = new SynchronizationContextScheduler(SynchronizationContext.Current);
ListA = new ListA();
ListB = new ListB();
ListC = new ListC();

GetItemsA().ToObservable()
.Zip(GetItemsB().ToObservable(), (a, b) => new { a, b, })
.Zip(GetItemsC().ToObservable(), (ab, c) => new { ab.a, ab.b, c, })
.ObserveOn(uiScheduler)
.Subscribe(abc =>
{
    ListA.Add(abc.a);
    ListB.Add(abc.b);
    ListC.Add(abc.c);
});

另一种解决方案可能是：

var a = Observable.Start(() => GetListA());
var b = Observable.Start(() => GetListB());
var c = Observable.Start(() => GetListC());

a.Zip(b, c, (x, y, z) => Tuple.Create(x, y, z))
    .ObserveOn(uiScheduler)
    .Subscribe(result =>
                 {
                   ListA = result.Item1;
                   ListB = result.Item2;
                   ListC = result.Item3;
                 });

我希望在创建集合后立即收集：

  a.ObserveOn(uiScheduler)
    .Do(l => ListA = l)
    .Zip(b, (la, lb) => lb)
    .ObserveOn(uiScheduler)
    .Do(l => ListB = l)
    .Zip(c, (lb, lc) => lc)
    .ObserveOn(uiScheduler)
    .Subscribe(listc => ListC = listc);
于 2012-09-24T06:28:22.090 回答
0

您也可以使用动态...：

void Main()
{
    var q =
    from @as in Observable.Start(() => GetItemsA())
    from bs in Observable.Start(() => GetItemsB())
    from cs in Observable.Start(() => GetItemsC())
    select @as.Cast<dynamic>().Concat(bs.Cast<dynamic>()).Concat(cs.Cast<dynamic>());   
    q.Subscribe(t => t.Dump()); 
}

// Define other methods and classes here
private IEnumerable<int> GetItemsA() {
    yield return 1;
    Thread.Sleep(500);
    yield return 2;
    yield return 3;
}
private IEnumerable<string> GetItemsB() {
    yield return "A";
    yield return "B";
    Thread.Sleep(1000);
    yield return "C";
}
private List<float> GetItemsC() {
    return new List<float> { 1.1f, 2.2f, 3.3f };
}
于 2012-11-21T20:33:16.633 回答