searchForDevice method

Implementation

@override
Stream<HeartRateDeviceInfo> searchForDevice() {
  late StreamController<HeartRateDeviceInfo> deviceStreamController;
  deviceStreamController =
      StreamController<HeartRateDeviceInfo>.broadcast(onListen: () async {
    _polar.searchForDevice().listen((event) {
      deviceStreamController.add(HeartRateDeviceInfo(
          deviceId: event.deviceId,
          address: event.address,
          rssi: event.rssi,
          name: event.name));
    }, onError: (error) {
      deviceStreamController.addError(HeartRateAdapterException(
          AdapterErrorType.libraryError,
          AdapterErrorType.libraryError.message,
          HeartRateDeviceEventStreamErrorType.unknown,
          detail: error));
    });
  });

  return deviceStreamController.stream;
}