일반 관찰 가능에서 PublishRelay를 구독하는 방법?

Question

코 틀린 번호 :

fun <T> Observable<T>.circuitBreaker(): Observable<T> { 
    val relay = PublishRelay.create<T>() 
    this.subscribe(relay) 
    return relay.toFlowable(BackpressureStrategy.LATEST).toObservable() 
} 

위 내가 스위프트로 변환하려고 해요 코 틀린 코드입니다.

extension Observable { 
    func circuitBreaker<T>() -> Observable<T> { 
    let relay = PublishRelay<T>() 
    self.subscribe(relay) 
    return relay.asObservable() 
    } 
} 

:

스위프트 코드 - 그러나, 나는 유형의 값 예상 인수 유형 'PublishRelay' '> 무효 (이벤트 < _>)을'변환 할 수 없습니다라는 오류에 직면하고있어 어떤 도움을 주시면 감사하겠습니다.

Answer 1

Observable을 Relay으로 바인딩 할 수 없습니다. 관련 토론 here을 참조하십시오.