通过Streambuilder监听流时跳过对象
通过StreamBuilder监听流时跳过对象是指在使用Flutter中的StreamBuilder组件监听数据流时，可以通过使用skip方法来跳过一些特定的对象。
StreamBuilder是Flutter中用于构建基于数据流的UI的组件。它接收一个数据流（Stream）作为输入，并根据数据流的变化来更新UI。当数据流中有新的事件（对象）时，StreamBuilder会重新构建UI以反映最新的数据。
在某些情况下，我们可能希望在监听数据流时跳过一些特定的对象，而不将它们包含在UI更新中。这可以通过使用Stream的skip方法来实现。skip方法接收一个整数参数，表示要跳过的对象数量。当有新的对象进入数据流时，StreamBuilder会自动跳过指定数量的对象，并将后续的对象传递给builder函数进行UI更新。
以下是一个示例代码，演示了如何使用StreamBuilder监听数据流并跳过对象：
Stream<int> getNumberStream() {
return Stream.periodic(Duration(seconds: 1), (i) => i).take(10);
}
Widget build(BuildContext context) {
return StreamBuilder<int>(
stream: getNumberStream().skip(3), // 跳过前3个对象
builder: (BuildContext context, AsyncSnapshot<int> snapshot) {
if (snapshot.hasData) {
return Text('当前数字: ${snapshot.data}');
} else {
return Text('等待数据...');
}
},
);
}在上面的示例中，getNumberStream函数返回一个每秒生成一个递增数字的数据流，并使用take方法限制只取前10个对象。在StreamBuilder中，我们通过调用skip(3)方法来跳过前3个对象。因此，UI只会显示从第4个对象开始的数字。
这种技术在处理数据流时非常有用，可以根据需要过滤或跳过特定的对象，以便更好地控制UI的更新。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云云开发（Serverless）：https://cloud.tencent.com/product/tcb
- 腾讯云云数据库 MySQL 版：https://cloud.tencent.com/product/cdb_mysql
- 腾讯云云服务器 CVM：https://cloud.tencent.com/product/cvm
- 腾讯云人工智能：https://cloud.tencent.com/product/ai
- 腾讯云物联网平台：https://cloud.tencent.com/product/iotexplorer
- 腾讯云移动开发：https://cloud.tencent.com/product/mobdev
- 腾讯云对象存储 COS：https://cloud.tencent.com/product/cos
- 腾讯云区块链服务：https://cloud.tencent.com/product/tbaas
- 腾讯云游戏多媒体引擎：https://cloud.tencent.com/product/gme
- 腾讯云音视频处理：https://cloud.tencent.com/product/mps
相关·内容
我有一个StreamBuilder，它侦听由包web_socket_channel：^1.1.0创建的流。
Stream getLocationsStream({LatLngBounds latLngBounds, LatLng location}) {
if (branchMapChannel == null)
branchMapChannel = IOWebSocketChannel.connect(wsEndpointURL("business/branch/maps"));
return branchMapChannel.stream;
}
Stream
浏览 0提问于2020-12-19得票数 1
回答已采纳
我使用的是firebase，我有以下代码：
Stream<QuerySnapshot> qs = FirebaseFirestore.instance
.collection("$mypath")
.orderBy(order)
.limit(10)
.startAfterDocument(lastDoc)
.snapshots();
当我将qs传递给StreamBuilder时，返回的快照可以执行snapshot.hasError。
StreamBuilder(
浏览 12提问于2021-06-12得票数 0
我有一个使用Cloud Firestore的Flutter项目。在我的一个小部件中，我有一个理想的从数据库读取快照的StreamBuilder。从理论上讲，我用于从远程服务器读取数据的API应该足够抽象，以便用不同的实现替换Firestore。
class Database {
Stream<QuerySnapshot> get snapshots => Firestore.instance.collection('entires').snapshots();
Stream<List<String>> get entries
浏览 2提问于2018-11-17得票数 1
我想在流到达StreamBuilder之前转换它，但不知道会是什么样子。作为测试，我创建了下面的简单倒计时。我想要做的是将CountDownConversion赋给StreamBuilder，但是如果我取消对它的注释，我会得到编译错误。我一直在阅读有关streams和StreamBuilder的文章，但在StreamBuilder之前还没有人看到过这种类型的转换。如果有人能给我提供线索，我将不胜感激。 import 'package:flutter/material.dart';
final Color darkBlue = Color.fromARGB(255, 18,
浏览 10提问于2021-02-05得票数 0
回答已采纳
我已经知道是否要将stream listen in method用于快照，所以我需要使用StreamSubscription，然后使用.cancel();将其释放
但是，如果使用构建方法下的streamBuilder从fisrstore获取数据，如果是的话，我是否也需要处理它呢？或者当我按下底部的时候它会被自己处理掉？
@override
Widget build(BuildContext context) {
return StreamBuilder(
stream: FirebaseFirestore.instan
浏览 2提问于2021-12-02得票数 2
回答已采纳
我想实现PersistentBottomSheet，但又不想使用setState()。想要实现抛出streamBuilder
我用setState试过下面的代码，但用的是StreamBuilder，它没有给出预期的结果
VoidCallback _showBottomSheetCallback;
@override
void initState() {
super.initState();
_showBottomSheetCallback = _showBottomSheet;
}
void _showBottomSheet() {
setState(
浏览 0提问于2019-04-21得票数 0
我知道一些帖子提供了这个错误的解决方案，但我仍然不明白如何在没有阻塞的情况下使用StreamController。我没有在我的代码中使用bloc模式，所有的解决方案都与bloc模式有关。 我有两个选项卡，当我单击选项卡时，正确地显示数据，但当我第二次单击选项卡时，它显示此错误。解决方案是使用流控制器或行为主题，但我不知道如何使用。 错误:错误状态:流已被监听。 提前谢谢。 home_page.dart StreamBuilder<List<Dashboard>>(
stream: _dashboardService.getData(),
浏览 24提问于2020-06-23得票数 0
2回答
当我在控制台或应用程序中更新数据库时，更改不会在应用程序中同步。我认为这是因为orderBy和索引设置，但评论他们没有帮助。我的代码出了什么问题？如何设置自动同步？
@override
Widget build(BuildContext context) {
return Scaffold(
drawer: DrawerMenu(),
appBar: AppBar(
title: Text('Заявки'),
),
body: StreamBuilder<QuerySnapshot>(
浏览 3提问于2020-07-11得票数 0
2回答
我尝试使用textfield从用户获得输入( string )，将输入添加到流中，并将字符串打印到不同的屏幕上，但我理解，不是字符串流生成器是打印null，而是因为流没有任何数据。但是我在流中添加了数据，一旦用户在textfield中键入某些内容并点击save.How，我就喜欢这个了吗？
流
StreamController NameStream = StreamController.broadcast();
向流中添加数据
textField()
textbuttion(
onPressed: () {
addNStream() {
浏览 4提问于2022-03-26得票数 0
2回答
StreamBuilder限制
、、、、
每当得到新事件时，StreamBuilder就会重新构建。这会导致导航(Navigator.push)方面的问题，因为如果在导航时接收新事件，则此触发器将重新生成。因为在构建小部件树时尝试导航，这将引发。
可以根据需要避免此问题。
建议的解决方法基本上是从获得流。还有：和
但是这意味着不能有StreamBuilder构建列表，如果还想从列表上的卡片中提供导航，就不能不断更新。例如在卡onPressed()中。。
因此，要刷新数据，必须使用拉刷新…
有人有更好的解决办法吗？或者是颤振团队致力于解决这一限制，例如允许防止重建，如果卡被用户点击？
更新：
TL;DR是刷新数据的唯一方式，因为必须缓存
浏览 1提问于2019-02-27得票数 4
我有一个包装在另一个StreamBuilder中的StreamBuilder。内部StreamBuilder将分页异步查询的结果加载到传入的ListView中。外部StreamBuilder发出具有用户指定的搜索文本的新查询，并构建新的内部StreamBuilder来侦听新查询。查询使用生成器函数生成流。 我注意到了一些非常奇怪的行为:当发出一个新的查询并用一个新的StreamBuilder重新构建内部的Stream时，它首先从前一个Stream接收数据。当新的Stream为空时，这一点尤其明显(例如，用户的查询没有产生任何结果)。如果新的流是空的，它将从ConnectionState.wa
浏览 24提问于2020-10-25得票数 1
我对颤振SDK很陌生，我创建了一个包含两个选项卡的颤振应用程序。
在第一个选项卡上，我有一个ListView，它显示来自FutureBuilder的项，该项目通过http获取数据。
在第二个选项卡上，我有一个ListView，它显示来自StreamBuilder的项，在从第一个选项卡将项添加到数据库后，还通过http获取数据。
问题是:当我来回切换选项卡时，第二个选项卡不会重新加载http调用并显示错误
坏状态:流已经被听过了。
除非我手动按下刷新按钮(这是一个setState(() {}))，否则它会再次加载，有什么方法可以让它在选项卡更改时重新加载？
这是我的http电话：
Future
浏览 3提问于2021-11-28得票数 2
回答已采纳
我有一个包含以下代码的类：
class GeofenceManager {
ReceivePort geofencingMessagePort = ReceivePort();
Stream<String> get events {
return geofencingMessagePort.map((event) => event.toString());
}
...
在我的UI中，我有这样一个StreamBuilder：
@override
Widget build(BuildContext context) {
super.bui
浏览 3提问于2020-11-23得票数 1
回答已采纳
我正在努力解决以下问题： 我使用StreamBuilder构建了一个小部件列表(并使其可搜索)。这些小部件是卡片，在它们里面，用户可以进行选择，然后按下按钮。一切都工作得很好。 然后，我想添加一些动画，并将与按钮关联的图标设置为动画图标。现在它是一团糟，StreamBuilder在无限循环中，我的列表上也有一些问题。如果我注释掉动画图标并重新放入，之前的图标...everything又开始正常工作了。 ...
child: FloatingActionButton(
onPressed: (){
浏览 10提问于2021-02-07得票数 0
我有一个包含视频缩略图的网格视图。现在，这个缩略图列表是从一个流生成的。我需要的是，当用户点击任何图像的特定视频应在页面视图中打开。我已经做到了这一点，但是在页面视图中打开的视频没有听到任何更改。 我不确定是否可以在网格视图和页面视图中使用相同的流。 下面是我的一些代码： StreamBuilder(
stream: Firestore.instance
.collection("videos")
浏览 1提问于2020-06-30得票数 0
我在状态小部件中使用以下StreamBuilder：
StreamBuilder<List<int>>(
stream: widget.model.results(widget.type),
builder: (context, snapshot) {
if (!snapshot.hasData) return CircularProgressIndicator();
if (snapshot.hasError) return Text('Error');
final List<int> results =
浏览 0提问于2021-07-23得票数 3
2回答
众所周知，flutter有一个使用websocket的示例，但是它只是接收websocket响应作为流，并且类似于这样的内容：
new StreamBuilder(
stream: widget.channel.stream,
builder: (context, snapshot) {
return new Text(snapshot.hasData ? '${snapshot.data}' : '');
},
);
我想要的是一个异步函数，它接收每个websocket响应并将结果附加到一个列表中，这样就可以更新listview。
如何获得
浏览 0提问于2018-05-23得票数 6
1回答
我在我的应用程序中应用了块模式，在通过底部导航更改屏幕时遇到了问题。 我试着做一个流广播，但是在改变屏幕后数据消失了。 这是我的Home类，它代表了主屏幕。 class Home extends StatefulWidget {
@override
_HomeState createState() => _HomeState();
}
class _HomeState extends State<Home> {
final DepartmentBloc departmentBloc = BlocProvider.getBloc<DepartmentBlo
浏览 18提问于2019-06-15得票数 1
我使用StreamBuilder和ListView在UI中显示来自FireStoreDatabase的数据。通常，当我在数据库中进行任何更改(不进行刷新)时，它会自我更新。但是当我对流中的数据进行排序时，它就不再更新了。下面是用于StreamBuilder的代码。
Stream<List<Attraction>> attractionsStream = Stream.value([]);
void initState() {
final database = Provider.of<Database>(context, listen: false)
浏览 2提问于2022-01-25得票数 0
我目前正在使用流构建器和未来构建器同时调用两个集合。我感到很困难，因为每次数据库更改时，流构建器都会刷新。这是我的源代码：
body: StreamBuilder<QuerySnapshot>(
stream: FirebaseFirestore.instance
.collection('thread')
.orderBy('published-time', descending: true)
.snapshots(),
buil
浏览 5提问于2021-10-22得票数 1
回答已采纳
我有两个流从两个不同的api获取。 Stream<Month> get monthOutStream => monthOutController.stream;
Stream<MySchedule> get resultOutStream => resultController.stream; 我在应用程序的两个不同状态下获取这些数据，开始时的结果和用户的一些事件后几个月的结果。 MyScheduleBloc(){
initialData();
}
Future initialData() async {
MySchedule mySchedul
浏览 56提问于2018-08-16得票数 31
回答已采纳
我希望三行共享一个流，每行都可以暂停和恢复。 现在，我只能使用StreamController和StreamBuilder共享一个流到三行，但我不知道如何暂停和恢复。 ? https://github.com/WingCH/Fluuter-Exercise ...
class StreamDemoState extends State<StreamDemo> {
StreamController _streamController;
Stream<int> timerStream;
@override
void initState() {
浏览 50提问于2020-01-05得票数 2
我有一个屏幕，它包含一个Form和一个StreamBuilder。当我从StreamBuilder加载初始数据时，TextFormField会按预期显示数据。
当我点击TextFormField内部时，软件键盘就会显示出来，这会导致小部件重新构建。当键盘再次下降时，同样的情况会再次发生。
不幸的是，StreamBuilder再次被订阅，文本框值被替换为初始值。
这是我的代码：
@override
Widget build(BuildContext context) {
return StreamBuilder(
stream: _bloc.inputObservable(),
浏览 0提问于2019-05-26得票数 21
1回答
我有一个有状态的小部件，它有一个动画容器。在动画容器中，我有一个连接到firebase的streamProvider。我的问题是，当我使用setState进行动画时，整个小部件都会重新构建，并且会再次调用firebase。我的解决方案是抬起streamProvider并包装使用streambuilder进行动画处理的小部件。但这意味着我需要创建另一个小部件，因此需要创建更多的样板。 我觉得我所做的是错误的，但我有点卡住了，因为所有的提供者资源都与身份验证相关…… 有没有人知道我怎么才能干净利落地解决这个问题呢？setState是在有状态窗口小部件中触发动画的正确方式吗？
浏览 12提问于2020-04-16得票数 0
回答已采纳
第一次打开ExpansionTitle时，一切都很好。在缩小和扩展它之后，我收到了一个“坏州”流已经听过了，错误。我尝试将流作为广播返回，但是在最小化和重新打开之后，快照是空的。我不太清楚在流中使用ExpansionTitle的合适技术是什么。
import 'package:flutter/material.dart';
void main() => runApp(MyApp());
class MyApp extends StatelessWidget {
@override
Widget build(BuildContext context) {
re
浏览 1提问于2019-02-12得票数 2
回答已采纳
今天，我遇到了一个关于streams和StreamBuilder的问题。问题是:如果您有多个StreamBuilder小部件侦听同一个流，并且将数据添加到它的接收器中，该数据将通过流输出--即您拥有的StreamBuilder侦听器数量，换句话说:如果您有一个StreamController (或BehaviorSubject)、k个StreamBuilder类型的小部件，并且尝试执行StreamController.sink.add(事件)，则该事件将在流中输出k次，每个StreamBuilder一个。这是否是一种预期的行为(预期行为=输入一个事件，并且只从另一方侦听一次，与侦听器的数量无关
浏览 12提问于2020-08-28得票数 3
回答已采纳
1回答
更新具有多个子部件的单个父部件与单独更新每个子部件之间的性能差异是什么。
哪一个性能更好，以及性能提高了多少：
StreamBuilder(
stream:sameStream,
builder(ctx,snapshot){
return Column(
children:[
Text("1"),
Text("2"),
Text("3")
]
)
}
)
或
Column(
children:[
StreamBuilder(
s
浏览 2提问于2020-05-23得票数 2
我正在使用StreamBuilder，并将StreamController.stream的一个实例放入其中。
late StreamController c;
late Stream s;
initState() {
c = StreamController();
s = c.stream;
super.initState();
}
Widget build(context) {
return StreamBuilder(
stream: s,
builder: (context, snap) {
return Container(
浏览 3提问于2021-12-09得票数 0
1回答
我有一个listview，它保存来自Firestore的文档，我希望每个listitem都能收到实时更新。
由于这个列表是由不同位置的文档构建的，所以我不能简单地听一个集合。相反，我需要单独听每一个listview item。这可能会在数百个同时侦听器中结束，这将是非常糟糕的，因为Firestore文档显示，每个应用程序实例最多可以有100个侦听器。
当listview.builder分别在滚动到视图时构造它的按需项和在滚动出视图时分别处理项目时，这会停止相应的侦听器吗？因此，只有侦听器处于活动状态，而当前正在查看这些侦听器。
下面是一个代码示例：
ListView.builder(
it
浏览 3提问于2022-08-03得票数 0
我正在使用瑞安海瑟只是音频和音频服务颤振包的无线电播放器应用程序。首先在main.dart中使用main.dart中的StreamBuilder ()，使用StreamBuilder侦听player.icymetadatastream，使用流生成器监听播放/暂停控件的回放状态。这个很好用。
现在添加了audio_service包，用于背景音频和iOS控制中心等。在main.dart中，我们用一个音频处理器初始化AudioService。controlbuttons.dart在audiohandler.playbackstate上使用StreamBuilder而不是player.playerSt
浏览 11提问于2022-09-19得票数 0
回答已采纳
我的代码中有一个具体化的内存状态存储。我有另一个单独的流，它应该根据一些标准来查找和删除记录。
我需要允许我的流访问和删除先前构建的状态存储中的记录。我有下面的代码
@bean
public StreamBuilder myStreamCodeBean(StreamBuilder streamBuilder) {
//create store supplier
KeyValueBytesStoreSupplier myStoreSupplier = Stores.inMemoryKeyValueStore("MyStateStore");
//mate
浏览 1提问于2020-03-14得票数 0
1回答
我有一个Bloc类，它需要基于同一流控制器的三个流。 class TodoBloc {
final _todoController = StreamController<List<TodoModel>>();
get allTodoStream => _todoController.stream;
get activeTodoStream => _todoController.stream
.map<List<TodoModel>>(
(list) => lis
浏览 19提问于2019-01-20得票数 3
我有这个StreamController：
StreamController<Workout> _selectedWorkoutSubject = new StreamController()
我在StreamBuilder中收听它，如下所示：
StreamBuilder(
stream: workoutBloc.selectedWorkoutStream,
builder: (BuildContext context, AsyncSnapshot<Workout> snapshot) {
if (snapshot.hasData) {
re
浏览 1提问于2019-02-11得票数 0
目前，我正在与块在颤振和我有一个问题，多个流在一个集团。
例如，当一个屏幕有多个小部件时，应该依赖于Bloc。我可以将整个屏幕包装在StreamBuilder中，但是每次都会重建所有的小部件。
举个例子：
class TestBloc {
final StreamController _dataController = StreamController<String>();
final StreamController _appBarTitleController = StreamController<String>();
TestBloc();
S
浏览 0提问于2019-07-12得票数 7
回答已采纳
我正尝试在我的无状态小部件上使用Rxdart： class SimplePrioritySelectWidget extends StatelessWidget {
BehaviorSubject<List<String>> _valueNotifier =
BehaviorSubject<List<String>>.seeded([]); 我用StreamBuilder包装我的小部件： @override
Widget build(BuildContext context) {
return StreamBui
浏览 66提问于2021-07-29得票数 0
回答已采纳
我构建了包含多个部件的应用程序homeScreen，其中大部分基本上是一个不同大小的listView，我将它们都放在列部件中。 问题是这个listView实际上来自streamBuilder，所以列表中的内容是动态的(来自firebase)，所以它可能会包含5个项目或0个项目。 据我所知，当我使用streambuilder或listview时，通常我需要将这个小部件扭曲到类似容器中的预定义高度，如果列表视图项仅为1，而我预定义的高度为5项，则它将显示为空白的大空白(因为容器用于5项，但对于该用户，他/她只有1项)。 Container(
height: screenHeight * 0.
浏览 11提问于2019-10-05得票数 0
2回答
我有一个这样的溪流组合列表；
var Stream1 = _firestore
.collectionGroup("Infos")
.where('ID', whereIn: List1)
.snapshots();
var Stream2 = _firestore
.collectionGroup("Infos")
.where('ID', whereIn: List2)
.snapshots();
var Stream3 = _firestore
浏览 5提问于2021-12-17得票数 0
这是我目前使用的内容的设置：
class BookList extends StatelessWidget {
@override
Widget build(BuildContext context) {
return StreamBuilder<QuerySnapshot>(
stream: Firestore.instance.collection('books').snapshots(),
builder: (BuildContext context, AsyncSnapshot<QuerySnapshot>
浏览 3提问于2019-10-20得票数 0
回答已采纳
我想向用户显示某个区域内的用户，但是使用geo查询时，我得到了一个错误。
类'List<DocumentSnapshot<Object?>>‘没有实例获取'docs’。
接收者：“_GrowableList”的实例(长度:1)
尝试呼叫: docs
Expanded (
child:StreamBuilder (
stream: geo.collection(collectionRef: FirebaseFirestore.instance.collection("use
浏览 4提问于2022-01-31得票数 1
回答已采纳
我使用的是一个Selector，当Bloc中的数据发生变化时，它会重新构建。这样做很好，但是当数据发生变化时，它会重新加载整个树，而不仅仅是Selector内部的构建器。
在我的例子中，选择器在StreamBuilder中。我需要这个，因为流是连接到API的。因此，在流中，我正在构建一些小部件，其中之一是Selector。Selector重新构建依赖于流的数据的小部件。
这是我的密码。我不想让流一次又一次地被调用。此外，流也会被调用，因为每次选择器小部件重新构建时都会调用build。
main.dart
import 'package:flutter/material.dart'
浏览 3提问于2020-01-02得票数 2
2回答
我看了一些类似的问题，但没有找到我要找的东西。我有一个快照没有数据的StreamBuilder，但是如果我查看它正在侦听的集合，我可以看到有两个文档。
这是我第一次使用StreamBuilder，所以我可能错过了一些基本的规则。我说它是has no data，因为它总是显示"No chats here"。
这是代码(稍后的流函数)：
StreamBuilder<ChatCard>(
stream: widget.database.streamChats(widget.user),
builder: (context, snapshot
浏览 3提问于2021-04-05得票数 0
回答已采纳
对于我正在构建的应用程序，我希望用户能够通过下面所示的CupertinoDatePicker输入特定的日期，并在我希望下面的列表视图动态更新之后立即输入。列表视图应该显示所有具有时间戳的帖子，时间戳位于用户指定日期之间。
以下是我的数据是如何在防火墙中被构造的。本质上，我有一个用户集合，每个单独的用户都有一些属性，比如他们的名字、等级等等，还有一个帖子的。每个帖子都会记录用户在表单中填写的信息，但最重要的是，它会在提交帖子时记录时间戳。这是一个清晰的截图。
我面临的问题是，当用户决定选择不同的日期时，列表视图不会更新。我的代码如下所示。
Container
浏览 4提问于2020-03-19得票数 0
我正在尝试从Firestore中检索数据。在StreamBuilder小部件的帮助下，我成功地做到了这一点。我想要的是将从firestore获得的数据传递到另一个屏幕。
我不想用ListView打印StreamBuilder，只想获取数据并传递到我从Navigator.push(...调用的下一个屏幕
这是我的get_news()方法，我在这里实现了获取数据的方法：
// get the news
Stream<List<News>> getNews() {
return _db.collection("news").snapshots(
浏览 1提问于2020-04-28得票数 0
我正在使用Firebase在我的应用程序中添加登录/注册。它是完美的工作，但现在我想检查用户是否已经注册和登录时，他打开的应用程序，如果这是真的，然后显示他的主页，否则显示他的登录页面。所以我做了一些搜索，主要是使用Streambuilder方法完成的。但我所做的只是检查用户是否使用 initialRoute: FirebaseAuth.instance.currentUser == null
? Routes.loginScreen
: Routes.homePage, 它工作得很好，几乎每个人都在使用Streambuilder方法。
浏览 9提问于2021-08-05得票数 3
回答已采纳
使用流生成器将其流设置为BehaviourSubject的流，每当重建父部件并调用streamBuilder的构建器函数时，快照连接状态仍在等待，尽管流中有以前的数据，但快照没有数据。然后立即使用活动连接再次调用构建器，并且快照具有最新的值。
行为stream的流中的最新值不应该在第一次访问吗？
浏览 2提问于2018-10-25得票数 3
回答已采纳
1回答
我正在构建一个应用程序，它大量使用streambuilder从应用程序的多个页面从消防站获取实时数据。
由于没有流关闭/流订阅取消方法，那么当框架释放小部件时，是否可以安全地假设streambuilder将自动分离侦听Fi还原文档更改？有什么需要注意的警告吗。
谢谢。
浏览 0提问于2019-04-13得票数 16
我有Kafka Streams应用程序如下：
static KafkaStreams build(AppConfig appConfig, SerdesHelper serdes) {
final KStreamBuilder builder = new KStreamBuilder();
builder
.table(serdes.sourceKeySerde, serdes.sourceValueSerde, appConfig.sourceTopic)
.groupBy(StreamBuilder::groupByMapper, serdes.intSe
浏览 0提问于2018-01-22得票数 3
回答已采纳
StreamBuilder总是打两次电话吗？一次用于初始数据，一次用于输入流？
初始化下面的StreamBuilder显示生成方法被调用了两次。第二次呼叫是第一次呼叫之后的0.4秒。
流:构建1566239814897
流:构建1566239815284
import 'dart:async';
import 'dart:ui';
import 'package:flutter/material.dart';
import 'package:nocd/utils/bloc_provider.dart';
void main()
浏览 0提问于2019-08-19得票数 7
回答已采纳
这是我的代码: StreamBuilder有一个错误
错误参数类型'Object?‘不能分配参数类型‘颜色？
body: Center(
child: StreamBuilder(
stream: bloc.stateStream,
initialData: Colors.amber,
builder: (context, snapshot) {
return AnimatedContainer(
duration: Duration
浏览 4提问于2021-06-07得票数 0
如何在StreamBuilder中添加TextField？我有一个TextField / TextFormField作为StreamBuilder或FutureBuilder的构建器函数中的一个小部件，每当我们试图与文本字段交互时，它只是刷新整个构建器小部件并再次调用流/未来。
body: StreamBuilder(
stream: getClientProfile().snapshots(),
builder: (context, snapshot) {
if (snapshot.connectionState == ConnectionState.
浏览 4提问于2018-07-28得票数 8
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
