connect method

Future connect()

链接服务器

Implementation

Future connect() async {
  if (isConnect == StatusEnum.close) {
    channel = platform.FlutterImSdk().getChannel(imAddress);
    channel.stream.listen((event) {
      isConnect = StatusEnum.connect;
      _onReceive(event);
    }, onError: (error) { //监听服务器消息
      isLogin = false;
      print("onError...." + error.toString());
      eventBus?.emit("immessage", IMManagerSubject("链接断开了" + error.toString() , "ERROR"));
    }, onDone: () {//连接错误时调用
      isLogin = false;
      print("onDone.................");
      eventBus?.emit("immessage", IMManagerSubject("链接断开了", "ERROR"));
    }, //关闭时调用
        cancelOnError: true //设置错误时取消订阅
    );

    return true;
  }
}