swe*_*olf 2 ios swift rx-swift rx-cocoa reactive
我正在尝试从AlamofireImage为ImageDownloader制作一个小的反应式包装:
import Foundation
import UIKit.UIImage
import AlamofireImage
import RxCocoa
import RxSwift
extension Reactive where Base: ImageDownloader {
public func download(urlRequest: URLRequest, filter: ImageFilter?) -> Observable<UIImage> {
return Observable.create { observer in
self.base.download(urlRequest, filter: filter) { response in
if let error = response.error {
observer.onError(error)
} else if let image = response.value {
observer.onNext(image)
}
}
return Disposables.create()
}
}
}
Run Code Online (Sandbox Code Playgroud)
它编译没有问题。但是,当我尝试调用rx.downloadImageDownloader的实例时,出现错误,提示那里没有'rx'扩展名:
任何猜测为什么会这样?
您需要先遵守ReactiveCompatible协议,然后才能在downloadRequest调用中使用“ rx”
import AlamofireImage
import RxSwift
extension ImageDownloader: ReactiveCompatible {}
extension Reactive where Base: ImageDownloader {
public func download(urlRequest: URLRequest, filter: ImageFilter?) -> Observable<UIImage> {
return Observable.create { observer in
let requestReceipt = ImageDownloader.default.download(urlRequest, filter: filter) { response in
if let error = response.error {
observer.onError(error)
} else if let image = response.value {
observer.onNext(image)
observer.onCompleted()
}
}
return Disposables.create {
requestReceipt?.request.cancel()
}
}
}
}
Run Code Online (Sandbox Code Playgroud)
现在您可以调用ImageDownloader.default.rx.download(urlRequest:filter:)如下方法
let imageRequest = URLRequest.init(url: URL(string: "https://imageserver.com/image/myimage.png")!)
let imageObservable: Observable<UIImage> = ImageDownloader.default.rx.download(urlRequest: imageRequest, filter: nil)
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
642 次 |
| 最近记录: |