AgoraRtmChannel(this._clientIndex, this.channelId) { _closed = false; _eventSubscription = _addEventChannel() .receiveBroadcastStream() .listen(_eventListener, onError: onError); }