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());
}