使用async函数和Reactive-Cocoa转换值数组

Question

我有一个String数组，我想通过对每个值调用一个异步函数来修改它。

我尝试了一些东西，但它只是创建了一个RACSignal的RACSequence，而不是一个修改后的String数组

func modifyValueAsynchronously(inputValue: String, completion: (String -> Void)) -> RACSignal  {
    return RACSignal.createSignal() { subscriber in
        doAServerCall(inputValue) { outputValue in
            subscriber.sendNext(outputValue)
        }
    }
}

let value: NSArray = ["a", "b"]

let result = value.rac_sequence.map({ value in
    return self.doRequest(value as! String)
})

Answer 1

正如您所说，您希望对数组中的每个字符串值执行一个异步函数。因为你是异步完成的，所以最终的结果也将是异步的。在获得RACSignal的RACSequence之后，您希望等待每个信号提供值，然后将其全部收集到数组中。

let transformation = { (input: String) -> RACSignal in
        return RACSignal.createSignal { subscriber in
            subscriber.sendNext(input + "a")
            return nil
        }
    }

    let array: NSArray = ["a", "b", "c", "d"]

    let sequence = array.rac_sequence.map({ (element) in
        return transformation(element as! String)
    })
    RACSignal.combineLatest(sequence).subscribeNext { (element) in
        let array = (element as! RACTuple).allObjects()
        print("Elements from array \(array) \n")
    }

让我们举个例子。转换闭包将为每个字符串异步添加一个'a‘字母。在创建序列之后，我添加了combineLatest运算符，一旦序列中的每个元素向我提供了它的结果，它就会给我结果。一旦我得到了所有的结果，我就会在subscribeNext方法中得到一个RACTuple，然后我就可以把它组成一个数组。