Building the Signals

gistfile1.txt

    func fetchJSON(from url: URL) -> RACSignal {
        print("Fetching: \(url.absoluteString)")
        // 1
        return RACSignal.createSignal({(_ subscriber: RACSubscriber) -> RACDisposable in
                // 2
            var dataTask = self.session.dataTask(withURL: url, completionHandler: {(_ data: Data, _ response: URLResponse, _ .error: Error) -> Void in
                    // TODO: Handle retrieved data
                })
            // 3
            dataTask.resume()
            // 4
            return RACDisposable(block: {() -> Void in
                dataTask.cancel()
            })
        }).doError({(_ error: Error) -> Void in
            // 5
            print("\(.error)")
        })
    }

   override init() {
        super.init()

        // 1
        self.locationManager = CLLocationManager()
        self.locationManager.delegate = self
        // 2
        self.client = WXClient()
        // 3
        RACObserve(self, currentLocation).ignore(nil).flattenMap({(_ newLocation: CLLocation) -> Void in
            return RACSignal.merge([self.updateCurrentConditions(), self.updateDailyForecast(), self.updateHourlyForecast()])
            // 6
        }).deliver(on: RACScheduler.mainThreadScheduler).subscribeError({(_ error: Error) -> Void in
            TSMessage.showNotification(withTitle: "Error", subtitle: "There was a problem fetching the latest weather.", type: TSMessageNotificationTypeError)
        })
    
    }