无法收听广播流

iDe*_*ode 7 dart rxdart

我的标准流:

var stream = (StreamController<int>()..add(1)).stream;
stream.listen(print); // prints 1
Run Code Online (Sandbox Code Playgroud)

我的直播流:

var stream = (StreamController<int>.broadcast()..add(1)).stream;
stream.listen(print); // doesn't print anything
Run Code Online (Sandbox Code Playgroud)

ede*_*nar 21

与标准流不同,当没有侦听器时,广播流不会缓冲事件。首先声明广播流,监听它然后添加事件。

var controller= StreamController<int>.broadcast();
controller.stream.listen(print); 
controller.sink.add(1); // will print 1
Run Code Online (Sandbox Code Playgroud)