问题标签 [rxdart]

我正在尝试使用 rxDart 向后端发出一个简单的请求。但是我面临的问题是，当我收到诸如 404 之类的 http 错误时，不会调用 onError，但是，可以在 onData 中将其提取出来。

我对 RxJava + 改造有一点经验，它可以按预期工作，当有一个错误响应时，http 状态代码 onError 被调用并且可以适当地处理。

1.我做错了什么，或者是故意的行为？

OnboardingRepository.dart：

TMApi.dart：

2. 在视图中处理事件的最佳方式是什么？如果发生错误应该显示错误，否则应该打开一个新屏幕。sendProfileData() 方法将返回一个对象，基于我将在视图中执行操作，但这听起来不是一个非常优雅的解决方案......

3. 欢迎任何关于架构的建议:)

我正在使用 RxDart 来观察变化并相应地更新 UI。当应用程序启动时，我正在进行网络调用并成功获取数据，观察更改并相应地更新 UI。但是当我Subjects在关闭屏幕的同时进行处理时。它给出以下错误：

这是 bloc 类：

这是我称之为的 UI 屏幕：

当我关闭屏幕时出现错误。dispose 方法抛出上述异常。我该如何解决这个问题？

我正在尝试使用 RxDart 将 Firestore 中的两个流合并为一个流，但它只返回一个流的结果

在 Flutter Redux Epic 中间件中，如何在流变量更改后调度动作？

EpicMiddleware 的一个简单示例：

在沙漏变量从 observable 更改后，我尝试了一些不同的方法来调度这个LoadHourglassesHistoryAction ，但不调度。是否可以在 Observable 更改后调度一个动作？

使用的包：
redux_epics：^0.10.0 & rxdart：^0.18.0

我有final _fetcher = PublishSubject<MyModel>() ;我的集团组件。这是结构MyModel：

还有

在集团。

我有两个页面，第一个显示MyObjectsinside列表Listview.builder，第二个显示选定MyObject数据。
我正在尝试从myObjects使用中获取数据StreamBuilder。
在第一页中，所有对象都完美显示。但是当我打开一个带有选定对象的页面时，我的AsyncSnapshot内部StreamBuilder总是在connections.state等待，尽管我有数据在流中。
我究竟做错了什么？

x是一个流。在每个事件上，我都会生成一个x_i本身会产生事件的流。从这个设置中，我想生成一个扁平的输出流，它只包含最近的事件x_i，直到x结束：

预期的结果是

我不能使用flatMapon x，因为这样所有x_i事件都会被合并到输出流中，而不仅仅是最近的子流中的事件。

我也不能使用concatMap，因为x_i是无限的，输出流实际上是x_1.

在我看来，这似乎是一个相当常见的场景，因此我的问题是：这可能使用标准 RxDart（我正在使用），还是我需要自己实现？

我有一个包含两个输入的表单：名称和地址以及一个保存按钮。

所以我为每个创建了一个更改和isValid命令

我正在尝试为保存按钮创建相同的位置canSave = _isNameValidCommand && _isAddressValidCommand，但无法弄清楚语法。

我创建了一个 ZipStream ：

但从不调用流。

有什么提示吗？

我正在使用带有 Rx_command、Rx_dart 的反应组件流/可观察对象进行开发

问题：

• 在我的 Flutter 应用程序中，我继承了可以在任何地方调用的小部件：

  FooProvider.of(context).foo.method1...

• 当 UI 首次加载时，我需要第一次调用该方法

• 我不能使用 init.state 因为这是不可能的

• 我使用didchangedependencies它可以工作，但是..

  ...每次 ui 重新加载时，都会调用didchangedependencies并再次执行该方法。

我不希望它被执行，我不能使用 init.state

如何只执行一次该方法？

有没有办法Dart像这样限制函数执行

Observable.throttle(myFunction,2000);

考虑这段代码（不要介意无用的listen方法，它只是为了展示用例）：

现在我知道这会起作用，但是有没有办法让generic type我NotifPromptModel在这种情况下使用参数传递给BehaviorSubject（在每个新的StreamController最后发送）？当我传递一个包含关于 的信息时，这将使我有方便的代码建议，就像在这种情况下一样。eventlistendataobjectmodelfieldsBehaviorSubject