如何从generic observable订阅PublishRelay?
科特林代码:
fun Observable.circuitBreaker(): Observable { val relay = PublishRelay.create() this.subscribe(relay) return relay.toFlowable(BackpressureStrategy.LATEST).toObservable() }
上面是一个我正试图转换成Swift的Kotlin代码。 但是,我正面临一个错误,说不能将types’PublishRelay’types的值转换为期望的参数types’(Event ) – > Void’
SWIFT代码:
extension Observable { func circuitBreaker() -> Observable { let relay = PublishRelay() self.subscribe(relay) return relay.asObservable() } }
任何帮助,将不胜感激。
你不能绑定和Observable
到Relay
。 请参阅相关的讨论。