Tag: rx swift

如何从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() } } 任何帮助，将不胜感激。