Operations Example

Example

class GetStopsOperation: GroupOperation {

    let completion: (inner: () throws -> Void) -> Void

    init(context: NSManagedObjectContext, completion: (inner: () throws -> Void) -> Void) {

        self.completion = completion

        // Line Operations
        let getLinesCall = API.GetLinesColors
        let downloadLinesOp = DownloadOperation(call: getLinesCall)
        let parseLinesOp = JSONUnmarshalOperation()
        let importLinesOp = ImportStopOperation(context: context)

        parseLinesOp.injectResultFromDependency(downloadLinesOp)
        importLinesOp.injectResultFromDependency(parseLinesOp)


        // Stops Operations
        let getStopsCall = API.GetStops(stopCode: nil, stopName: nil, line: nil, latitude: nil, longitude: nil)
        let downloadStopsOp = DownloadOperation(call: getStopsCall)
        let parseStopsOp = JSONUnmarshalOperation()
        let importStopsOp = ImportStopOperation(context: context)

        parseStopsOp.injectResultFromDependency(downloadStopsOp)
        importStopsOp.injectResultFromDependency(parseStopsOp)

        // Synchronisation
        importStopsOp.addDependency(importLinesOp)

        super.init(operations: [])

        name = "Get Stops operations"

        addCondition(MutuallyExclusive<GetStopsOperation>())
        addOperations(downloadLinesOp, parseLinesOp, importLinesOp, downloadStopsOp, parseStopsOp, importStopsOp)
    }

    override func operationDidFinish(errors: [ErrorType]) {
        print("Errors: \(errors)")

        self.completion { 
            if let error = errors.first {
                throw error
            }
        }
    }
}