scanAddBleDevice method

Implementation

Stream<Map<String, dynamic>> scanAddBleDevice() {
  //判断没有关闭将继续使用
  if (_scanStreamController != null && !_scanStreamController!.isClosed) {
    return _scanStreamController!.stream;
  }
  _scanStreamController = StreamController.broadcast(onListen: () {
    //启动监听启动扫描
    methodChannel
        .invokeMethod(MethodName.scanAddBleDevice)
        .catchError((err) => {})
        .then((value) => {});
  }, onCancel: () {
    methodChannel.invokeMethod(MethodName.stopAddBleDevice); //取消监听停止扫描
  });
  _scanStreamController
      ?.addStream(_restoreStateEvents, cancelOnError: true)
      .then((value) {
    _scanStreamController?.close();
  });
  return _scanStreamController!.stream;
}