rxswiftcommunity / rxcorelocation Goto Github PK

public var location: Observable<CLLocation?> 
    let updatedLocation = self.didUpdateLocations.map { $1.last } // <--- possible memory effect here?
    let location =  self.observe(CLLocation.self, .location)
    return Observable.of(location, updatedLocation).merge()
}

import CoreLocation

import RxSwift
import RxCoreLocation

class GeolocationService: NSObject {

  var locationManager: CLLocationManager!

  var currentPlacemark: CLPlacemark?
  var currentLocation: CLLocation? {
    return currentPlacemark?.location
  }

  var disposeBag = DisposeBag()

  convenience init(withLocationManager loc: CLLocationManager) {
    self.init()
    locationManager = loc
    locationManager.desiredAccuracy = kCLLocationAccuracyNearestTenMeters
    locationManager.requestWhenInUseAuthorization()
    locationManager.startUpdatingLocation()

    locationManager.rx.placemark.subscribe(onNext: { [unowned self] placemark in
      self.currentPlacemark = placemark
    }).disposed(by: disposeBag)
  }

  deinit {
    locationManager.stopUpdatingLocation()
  }

  func getCurrentLocation() -> (latitude: Double, longitude: Double)? {
    guard let lat = currentLocation?.coordinate.latitude,
      let lon = currentLocation?.coordinate.longitude else { return nil }
    return (latitude: lat, longitude: lon)
  }

  func getCurrentAddress() -> Address? {
    guard let cPlacemark = currentPlacemark else { return nil}

    let address = Address(street: cPlacemark.name, zipCode: cPlacemark.postalCode, city: cPlacemark.locality, country: cPlacemark.country)

    return address
  }
}

class CoreLocationService: LocationService {

    private let locationManager: CLLocationManager
    private let disposeBag = DisposeBag()

    init(locationManager: CLLocationManager) {
        self.locationManager = locationManager
    }

    public func requestLocation() -> Single<CLLocationCoordinate2D> {
        return Single.deferred {
            return Observable.create { [unowned self] (observer) in
                let locationError = self.locationManager
                    .rx
                    .didError
                    .subscribe( onNext: { (_, error) in
                        observer.onError(error)
                    })

                let location = self.locationManager
                    .rx
                    .didUpdateLocations
                    .filter { $1.count > 0 }
                    .map { $1.last!.coordinate }
                    .subscribe(observer)

                self.locationManager.requestLocation()

                let cancel = Disposables.create(with: {
                    self.locationManager.stopUpdatingLocation()
                })

                return CompositeDisposable(cancel, locationError, location)
            }.take(1).asSingle()
        }
    }
}

    @available(iOS 9.3, OSX 10.11, *)
    public var didReceiveRegion: RxCocoa.ControlEvent<CLRegionEvent> { get }

import CoreLocation
import RxSwift
import RxCocoa

extension CLLocationManager: HasDelegate {
    public typealias Delegate = CLLocationManagerDelegate
}

public class RxCLLocationManagerDelegateProxy
    : DelegateProxy<CLLocationManager, CLLocationManagerDelegate>
    , DelegateProxyType
    , CLLocationManagerDelegate {

    public init(locationManager: CLLocationManager) {
        super.init(parentObject: locationManager, delegateProxy: RxCLLocationManagerDelegateProxy.self)
    }

    public static func registerKnownImplementations() {
        self.register { RxCLLocationManagerDelegateProxy(locationManager: $0) }
    }

    internal lazy var didUpdateLocationsSubject = PublishSubject<[CLLocation]>()
    internal lazy var didFailWithErrorSubject = PublishSubject<Error>()

    public func locationManager(_ manager: CLLocationManager, didUpdateLocations locations: [CLLocation]) {
        _forwardToDelegate?.locationManager?(manager, didUpdateLocations: locations)
        didUpdateLocationsSubject.onNext(locations)
    }

    public func locationManager(_ manager: CLLocationManager, didFailWithError error: Error) {
        _forwardToDelegate?.locationManager?(manager, didFailWithError: error)
        didFailWithErrorSubject.onNext(error)
    }

    deinit {
        self.didUpdateLocationsSubject.on(.completed)
        self.didFailWithErrorSubject.on(.completed)
    }
}

./Carthage/Checkouts/RxCoreLocation/Sources/Helpers.swift:10:12: error: no such module 'RxSwift'
    import RxSwift
           ^
/var/folders/jk/yh46dz450lg28bywvt4jyslm0000gn/T/carthage-xcframework-SxNw/RxCocoa.framework/Modules/RxCocoa.swiftmodule/arm64-apple-ios.swiftinterface:7:8: error: no such module 'RxCocoaRuntime'
import RxCocoaRuntime
       ^
/var/folders/jk/yh46dz450lg28bywvt4jyslm0000gn/T/carthage-xcframework-SxNw/RxCocoa.framework/Modules/RxCocoa.swiftmodule/arm64-apple-ios.swiftinterface:7:8: error: no such module 'RxCocoaRuntime'
import RxCocoaRuntime
       ^
/var/folders/jk/yh46dz450lg28bywvt4jyslm0000gn/T/carthage-xcframework-SxNw/RxCocoa.framework/Modules/RxCocoa.swiftmodule/arm64-apple-ios.swiftinterface:7:8: error: no such module 'RxCocoaRuntime'
import RxCocoaRuntime
       ^
/var/folders/jk/yh46dz450lg28bywvt4jyslm0000gn/T/carthage-xcframework-SxNw/RxCocoa.framework/Modules/RxCocoa.swiftmodule/arm64-apple-ios.swiftinterface:7:8: error: no such module 'RxCocoaRuntime'
import RxCocoaRuntime

⚠️ Reentrancy anomaly was detected.
  > Debugging: To debug this issue you can set a breakpoint in /Users/huangqc/Library/Developer/Xcode/DerivedData/HiNen-cpfnagrkwcupnlcdabhuytikjqaf/SourcePackages/checkouts/RxSwift/Sources/RxSwift/Rx.swift:96 and observe the call stack.
  > Problem: This behavior is breaking the observable sequence grammar. `next (error | completed)?`
    This behavior breaks the grammar because there is overlapping between sequence events.
    Observable sequence is trying to send an event before sending of previous event has finished.
  > Interpretation: This could mean that there is some kind of unexpected cyclic dependency in your code,
    or that the system is not behaving in the expected way.
  > Remedy: If this is the expected behavior this message can be suppressed by adding `.observe(on:MainScheduler.asyncInstance)`
    or by enqueuing sequence events in some other way.

⚠️ Reentrancy anomaly was detected.
  > Debugging: To debug this issue you can set a breakpoint in /Users/huangqc/Library/Developer/Xcode/DerivedData/HiNen-cpfnagrkwcupnlcdabhuytikjqaf/SourcePackages/checkouts/RxSwift/Sources/RxSwift/Rx.swift:96 and observe the call stack.
  > Problem: This behavior is breaking the observable sequence grammar. `next (error | completed)?`
    This behavior breaks the grammar because there is overlapping between sequence events.
    Observable sequence is trying to send an event before sending of previous event has finished.
  > Interpretation: This could mean that there is some kind of unexpected cyclic dependency in your code,
    or that the system is not behaving in the expected way.
  > Remedy: If this is the expected behavior this message can be suppressed by adding `.observe(on:MainScheduler.asyncInstance)`
    or by enqueuing sequence events in some other way.