问题标签 [rxdart]

在 Flutter 中，我有一个带有滑块的视图，其中包含许多文本字段的网格。我计划将每个文本字段附加到它自己的流（使用流构建器），从而产生数百个同时运行的流。我的问题是：这会导致性能方面的问题吗？

我想将StatelessWidget与BottomNavigationBar一起使用，我将从 BLOC 中控制它。我可以将Scaffold的主体和BottomNavigationBar的onTap连接到 BLOC（参见代码）。但我不明白如何从 BLOC（来自 Observable）设置BottomNavigationBar的currentIndex。

是否有任何好的解决方案，或者我是否需要像https://stackoverflow.com/a/53019841/936780中那样使用StatefulWidget ，这与我的示例类似。

集团代码：

小部件代码：

我正在尝试从互联网上获取一些数据。使用FutureBuilder，处理离线、在线、错误等各种情况非常容易，但我正在使用StreamBuilder，但我无法理解如何处理离线情况

以下是我使用 StreamBuilder 的代码，它有效，但我没有处理离线数据或错误

现在要处理离线案例，我正在执行以下两个选项，这些选项在我的案例中不起作用

选项一。

我一直CircularProgressIndicator在控制台上看到并且没有错误。我不明白为什么上述开关盒适用于FuturBuilder而不适用StreamBuilder。

第二种选择。

使用此选项会引发以下错误

使用StreamBuilder时出现以下离线、在线和错误数据的情况应该采取什么方法

我试图在屏幕关闭后从屏幕取回数据，然后将其添加到我的 BLoC 中的流控制器。但是，当我尝试使用 _bloc.streamController.value 检索值时，它为空。流控制器是一个 BehaviorSubject。

我尝试过的其他选项包括在 then 语句中调用 sink.add，将我的 bloc 传递给函数。

如果我删除“异步”和“等待”并硬编码一个值，它似乎可以工作。为什么异步导致我的数据无法保存到我的流控制器？

如何从屏幕返回数据并将其添加到我的流控制器？

嗨，我在 BLoC 类中使用 BehaviorSubject。我面临的主要问题是即使在调用之后drain()，close()最终值仍然保留在主题中。我怎样才能重置它？

完整项目链接：https ://github.com/SAGARSURI/Goals

这是我的代码。即使在对其调用和方法之后，也始终返回_title最终值：_goalMessagedrain()close()

我有一个包含字符串值的流，我想获取该字符串中的最后一个值。最好的方法是什么？

我在我的 BLOC 中收到错误“类型‘Future’不是‘StreamTransformer，List>’类型的子类型”。

这是我的应用程序的结构：一个 BLOC（即，reports_bloc）。一个Repository（即repository）。一个 API Provider（即 api_provider）。

详细地说，API Provider 文件在线获取数据。Repository 文件准备好来自 API Provider 的数据（实际上，我也在使用 DB，这也是我选择使用 Repository 文件的原因）。BLOC 旨在从 Repository 获取数据并相应地将其添加到 Stream 和 Sink。我相信问题出在 BLOC 中（关于添加到 Stream 和“下沉”数据，我可能在这里弄错了）。

代码在这里：

预期的结果是能够从存储库添加数据并接收它。

我正在尝试在 rxdart 中实现 bloc 模式。我正在尝试构建 app 类型的 todo 应用程序。我实现了显示列表中的所有项目，但我想要的不是在不同部分显示已完成和未完成的项目。但是，我无法根据完成的 rxdart 过滤项目。

我想要的是获得完成的 shoppingItems 。ShoppingItem 类有一个布尔属性 completed 。我想在此基础上对其进行过滤。

任何帮助将不胜感激

我尝试使用 Flutter rxdart 流从 jsonPlaceHolder 获取 List 并尝试在其上应用 bloc 模式。

此类响应从 api 获取发布响应

我使用存储库类使用 ItemApi 类进行包装

最后我使用 bloc 类来响应获取数据并将其设置在 PublishSubject 中

我的问题是如何在 _streamOfJsonList 变量中设置响应以在列表更改时使用它。

向 RxDart 添加侦听器时，PublishSubject我得到一个StreamSubscription. 然后我可以使用StreamSubscription来暂停和恢复，有没有办法用 来做到这一点StreamBuilder？