问如何构造rxjs代码

EN

如何构建一个rxjs应用程序？有大约100个玩具介绍示例，但没有一个完整的应用程序示例，其中包含小部件、子小部件等，显示整个应用程序中的数据流。

例如，假设你有一个具有某种状态的可观察对象。您需要将其传递给一个小部件。该小部件具有需要该状态的某些部分的子小部件。你订阅了吗？

sub = state.subscribe(widget)

现在'widget‘已经在monad之外了。子小部件不能在状态上使用可观察的方法。如果将小部件作为副作用运行，您也会遇到同样的问题。

state.doAction(widget)

那么，您是否将流传递给widget？如果是这样，你会得到什么回报？

what = widget(state)

小部件是否订阅状态并返回一个可处理的？它是否返回从state派生的流？如果是这样的话，里面有什么？您是否尝试广泛使用selectMany(identity)从所有小部件/子小部件/子子小部件收集所有流，以获得您订阅的最终应用程序流，从而启动整个过程？

如果小部件根据状态按需创建子小部件，那么小部件如何管理其子小部件？我一直在尝试使用groupBy()解决方案，每个子部件都有一个组，但是管理从嵌套的observable返回的所有订阅或流是一场令人难以置信的噩梦。

即使是整个应用程序的一个示例也会很有帮助。