1

我有这个结果数据类型,它包含一个类型和一个进度

public enum <T> {
    case Success(T)
    case Progress(CGFloat)
}

class func rx_request(router: Router) -> Observable<<AnyObject>>

AnyObject需要转换成一个Mappable结构(ObjectMapper),所以因为我有几个这样的 Mappable 结构,所以我想实现这样的东西,一个我可以使用的通用映射:

class func rx_convert<T : Mappable>(value: <AnyObject>) -> Observable<<T>> {

        return Observable.create { observer in

            switch value {
            case .Success(let object):
                guard let convertedObject = Mapper<T>().map(object) else {
                    observer.onError(NetworkError.IncorrectDataReturned)
                    return NopDisposable.instance
                }

                observer.on(.Next(<T>.Success(convertedObject)))
                observer.on(.Completed)

            case .Progress(let progress):
                observer.on(.Next(<T>.Progress(progress)))
                break
            }

            return NopDisposable.instance
        }
}

上面的定义似乎是错误的,因为无法编译:Cannot explicitly specialize a generic function

.flatMapLatest({ _ in
    .rx_request(Router.Pipeline)
})
.flatMapLatest({ result -> Observable<<ResponsePipeline>> in
    .rx_convert<ResponsePipeline>(result)
    // Cannot explicitly specialize a generic function
})

我在这里做错了什么?

4

1 回答 1

3
.flatMapLatest({ result -> Observable<<ResponsePipeline>> in
    return .rx_convert(result)
})

因为传递给的闭包flatMapLatest已经被类型化为返回一个Observable<<ResponsePipeline>>,编译器可以推断出类型,rx_convert以便您可以从调用<AnyObject> -> Observable<<ResponsePipeline>>中删除。<ResponsePipeline>

于 2016-03-29T15:00:48.450 回答