我正在尝试创建一个适用于数组的 Rx 运算符。我试过这个简单的扩展:
extension ObservableType where Element == Array<Any> {
func beat<U>(_ beat: Observable<U>) -> Observable<Element.Element> {
let lhs = self.flatMap { Observable.from($0) }
return Observable.zip(lhs, beat).map { $0.0 }
}
}
现在,我已经注意到Array<Any>
,否则我会得到
Reference to generic type 'Array' requires arguments in <...>
,但是这样返回值当然是Observable<Any>
。
Element
甚至可以用数组的实际值返回一个 observable吗?