Kotlin代码:
fun <T> Observable<T>.circuitBreaker(): Observable<T> {
val relay = PublishRelay.create<T>()
this.subscribe(relay)
return relay.toFlowable(BackpressureStrategy.LATEST).toObservable()
}
上面是一个Kotlin代码,我试图将其转换为Swift。但是,我正面临一个错误,说不能将'PublishRelay'类型的值转换为预期的参数类型'(Event <_>) - > Void'
SWIFT代码:
extension Observable {
func circuitBreaker<T>() -> Observable<T> {
let relay = PublishRelay<T>()
self.subscribe(relay)
return relay.asObservable()
}
}
任何帮助,将不胜感激。
你不能绑定和Observable
到Relay
。参见相关讨论here。
我用下面的方法做到了:
extension Observable {
func circuitBreaker<T>() -> Observable<T> {
let relay = PublishSubject<T>()
_ = self.subscribe { (event: Event<Element>) in
if let event = event as? Event<T> { relay.on(event) }
}
return relay.asObservable()
}
}