对副作用感到困惑/之后继续

Question

我有一个场景，我从api下载父实体并将它们保存到数据库中。然后我想，一旦所有的父母都被保存，下载并保存他们的孩子。

我已经看到(或误解)了一些关于这是一个副作用的评论，因为我不会将父保存操作的结果传递给保存子操作。我只是想等父母得救了再开始。

谁能告诉我做这件事的最好方法是什么?

Answer 1

也许可以试试这样做:

Observable
    .Create<int>(o =>
    {
        var parentIds = new int?[] { null };
        return
            Observable
                .While(
                    () => parentIds.Any(),
                    parentIds
                        .ToObservable()
                        .Select(parentId => Save(parentId)))
                        .Finally(() => { /* update `parentIds` here with next level */ })
                .Subscribe(o);
    })
    .Subscribe(x => { });

这实际上是对所有实体进行宽度优先遍历，在遍历过程中保存它们，但输出一个可以订阅的可观察对象。