Flutter DataStream не закрывается и не перестраивается должным образом. [Плохое состояние: поток уже прослушан.]

Конструктор по умолчанию StreamController создает поток, который допускает только одного слушателя.

StreamController({void onListen(), void onPause(), void onResume(), dynamic onCancel(), bool sync: false })
A controller with a stream that supports only one single subscriber. [...]

Если вы хотите иметь прослушиватель мультиплексора, используйте broadcast именованный конструктор.

factory StreamController.broadcast({void onListen(), void onCancel(), bool sync: false })
A controller where stream can be listened to more than once. [...]

Если вы хотите, чтобы у вашего потока был только один подписчик, не забудьте отменить подписку в dispose методе виджета.

DataStream stream;
StreamSubscription subscription;

@override
void initState() {
  super.initState();
  subsription = widget.stream.listen((onData) {
    changeText();
  });
}

@override
void dispose() {
  subscription?.cancel();
  super.dispose();
}

Просто имейте в виду, что это неправильный способ перестроить пользовательский интерфейс на основе потоковых событий. Взгляните на класс Stream Builder.

Что бы я сделал, так это переместил поток на StatefulWidget и воссоздал его, нажав "В Splash"

В реальном сценарии поместите его в виджет с отслеживанием состояния в дереве виджетов, где все виджеты, которым нужен доступ, смогут его найти (в вашем случае даже выше, чем навигатор).

import 'package:flutter/cupertino.dart';
import 'dart:async';
import 'package:flutter/material.dart';

void main() => runApp(MyApp());

class MyApp extends StatelessWidget {
  // This widget is the root of your application.
  @override
  Widget build(BuildContext context) {
    return CupertinoApp(
      title: 'Splash Test',
      theme: CupertinoThemeData(
        primaryColor: Color.fromARGB(255, 0, 0, 255),
      ),
      home: MyHomePage(title: 'Splash Test Home Page'),
    );
  }
}

class MyHomePage extends StatefulWidget {
  MyHomePage({Key key, this.title}) : super(key: key);

  final String title;

  @override
  _MyHomePageState createState() => _MyHomePageState();
}

class _MyHomePageState extends State<MyHomePage> {
  bool textBool = false;
  int counter = 0;

  DataStream stream = DataStream();

  void changeTest(context) async {
    setState(() {
      stream = DataStream();
    });
    int counter = 0;
    Timer.periodic(Duration (seconds: 2), (Timer t) {
      counter++;
      stream.dataSink.add(true);
      if (counter >= 3) {
        t.cancel();
        stream.dispose();
        Navigator.pop(context);
      }
    },);
    Navigator.push(context, CupertinoPageRoute(builder: (context) => Page2(stream: stream)));
  }

  @override
  Widget build(BuildContext context) {
    return CupertinoPageScaffold(
      child: Center(
        child: CupertinoButton(
          child: Text('To Splash'),
          onPressed: () => changeTest(context),
        ),
      ),
    );
  }
}



class DataStream {
  StreamController _streamController;

  StreamSink<bool> get dataSink =>
      _streamController.sink;

  Stream<bool> get dataStream =>
      _streamController.stream;

  DataStream() {
    _streamController = StreamController<bool>();
  }

  dispose() {
    _streamController?.close();
  }

}



class Page2 extends StatefulWidget {

  DataStream stream;
  Page2({this.stream});

  @override
  State<StatefulWidget> createState() => new PageState();
}

class PageState extends State<Page2> {


  bool textChanger = false;
  bool firstText = true;

  Text myText() {
    if (textChanger) {
      Text text1 = new Text('Text One',
          style: TextStyle(color: Color.fromARGB(255, 0, 0, 0)));
      return text1;
    } else {
      Text text1 = new Text('Text Two',
          style: TextStyle(color: Color.fromARGB(255, 0, 0, 0)));
      return text1;
    }
  }

  void changeText() {
    if (!firstText) {
      if (textChanger) {
        print('Change One');
        setState(() {
          textChanger = false;
        });
      } else {
        print('Change Two');
        setState(() {
          textChanger = true;
        });
      }
    } else {
      firstText = false;
    }
  }


  @override
  Widget build(BuildContext context) {
    return new Scaffold(
      body: new Container(
          child: Center(
              child: myText()
          )
      ),);
  }

  @override
  void initState() {
    super.initState();
    widget.stream.dataStream.listen((onData) {
      changeText();
    });
  }


}

Не имея возможности полностью понять вашу проблему, я просто хотел бы заявить, что у меня были головные боли практически каждый раз, когда я сам использовал "нормальные" потоки и RxDart был для меня как аспирин в мире потоков :) Не уверен, что это тот ответ, который вы ищете, но я подумал все равно опубликуйте - мало ли!

Ага! Мне удалось в этом разобраться. (Спасибо всем за попытку помочь, это действительно очень ценно). На самом деле это была действительно глупая ошибка новичков: как только я сделал шаг назад, я увидел это.

Вы заметите, что в файле main.dart у меня есть строка

DataStream stream = DataStream();

И у меня это установлено как глобальная переменная. Таким образом, любая из частей программы может получить доступ к информации по мере необходимости. Вот как мне нужно это настроить ... Но я забыл, что это можно создать.

Я изменил его на:

DataStream stream;

А потом в моем файле main.dart, незадолго до нажатия навигатора, я добавляю строку

stream = new DataStream();
Navigator.push(context, CupertinoPageRoute(builder: (context) => Page2(stream: stream)));

Итак, теперь я создаю новый экземпляр потока после того, как он был должным образом удален из более ранних частей программы. хлопает головой. Надо было понять это неделю назад.