init method
void
init()
Implementation
void init() {
_controller = StreamController<dynamic>.broadcast(
onListen: () async {
try {
await _sub();
} catch (e, stack) {
_controller!.addError(e, stack);
}
},
onCancel: () => _unsub());
}