Flutter: как получить все данные из потока, а затем прослушивать тот же поток на предмет новых обновлений?

Question

Как я могу прослушать поток в какой-то момент, чтобы сначала были доставлены все данные, доступные в потоке, а затем обновления также прослушивались всякий раз, когда они приходят.

StreamController<String> controller = StreamController<String>.broadcast();
Stream stream = controller.stream;;
StreamSubscription<String> streamSubscription = stream.listen((value) {
      print('Value from controller: $value');
}); 
controller.sink.add("1"); // prints "Value from controller: 1"
controller.sink.add("2"); // prints "Value from controller: 2"

stream.someMethod() ; // prints
                      // Value from controller: 1
                      // Value from controller: 2
controller.sink.add("3"); // prints "Value from controller: 3" by the someMethod()

В приведенном выше примере someMethod() сначала распечатает все доступные значения в потоке, а затем при добавлении новых данных в поток.

Как я могу этого добиться?

Answer 1

Оформить заказ rxdart предметов, возможно, у них есть то, что вы ищете.