0

在我的应用程序中，我有几个流。

这是来自appsflyer 的示例应用程序。我用它来深度链接我的应用程序。

https://pub.dev/packages/appsflyer_sdk

在第一页我们有；

return Scaffold(
  appBar: AppBar(
    title: Column(
      children: <Widget>[
        Text('AppsFlyer SDK example app'),
        FutureBuilder<String>(
            future: _appsflyerSdk.getSDKVersion(),
            builder: (BuildContext context, AsyncSnapshot snapshot) {
              return Text(snapshot.hasData ? snapshot.data : "");
            })
      ],
    ),
  ),
  body: FutureBuilder<dynamic>(
      future: _appsflyerSdk.initSdk(
          registerConversionDataCallback: true,
          registerOnAppOpenAttributionCallback: true),
      builder: (BuildContext context, AsyncSnapshot snapshot) {
        if (snapshot.connectionState == ConnectionState.waiting) {
          return Center(child: CircularProgressIndicator());
        } else {
          if (snapshot.hasData) {
            return HomeContainer(
              onData:
                  _appsflyerSdk.conversionDataStream?.asBroadcastStream(),
              onAttribution: _appsflyerSdk.appOpenAttributionStream
                  ?.asBroadcastStream(),
              trackEvent: logEvent,
            );
          } else {
            return Center(child: Text("Error initializing sdk"));
          }
        }
      }),
);

在 HomeContainer 中

  Stream<Map> onData;
  Stream<Map> onAttribution;
  Future<bool> Function(String, Map) trackEvent;

  HomeContainer({this.onData, this.onAttribution, this.trackEvent});

内部构建；

Column(
            children: <Widget>[

              StreamBuilder<dynamic>(
              stream: widget.onData,
              builder:
                  (BuildContext context, AsyncSnapshot<dynamic> snapshot) {
                return TextBorder(
                  controller: TextEditingController(
                      text: snapshot.hasData
                          ? Utils.formatJson(snapshot.data)
                          : "No conversion data"),
                  labelText: "Conversion Data:",
                );
              }),
              Padding(
                padding: EdgeInsets.only(top: 12.0),
              ),
              StreamBuilder<dynamic>(
              stream: widget.onAttribution,
              builder:
                  (BuildContext context, AsyncSnapshot<dynamic> snapshot) {
                return TextBorder(
                  controller: TextEditingController(
                      text: snapshot.hasData
                          ? _processData(snapshot.data)
                          : "No attribution data"),
                  labelText: "Attribution Data:",
                );
              }),
             
            ],
          ),

我所做的是使用 notifyListeners 放置一个按钮来重新加载屏幕。

当我这样做时，我会收到以下错误；

Bad state: Stream has already been listened to.

我认为，问题可能是由于我重新加载页面时这些流仍然打开。

但我不知道如何关闭它们。

任何人都可以提供一些帮助吗？

4

1 回答 1

1 
StreamBuilder<dynamic>(
  stream: widget.onData?.asBroadcastStream(),

您在.asBroadcastStream()上多次调用（每次调用 build 方法时）widget.onData。你应该能够使用：

StreamBuilder<dynamic>(
  stream: widget.onData,

如果widget.onData在其他地方收听，请确保widget.onData自己是广播流。

于 2021-01-08T09:35:10.580 回答