Código Kotlin:

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

Arriba hay un código de Kotlin que estoy tratando de convertir en Swift. Pero, me enfrento a un error que dice No se puede convertir el valor del tipo 'PublishRelay' al tipo de argumento esperado '(Evento <_>) -> Void'

Código Swift:

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

Cualquier ayuda sería apreciada.

0
Dinesh Raja 8 nov. 2017 a las 10:02

2 respuestas

La mejor respuesta

Lo hice usando a continuación:

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()
  }
}
0
Dinesh Raja 22 may. 2018 a las 10:20

No puede vincular y Observable a Relay. Consulte el debate relacionado aquí.

0
Timofey Solonin 8 nov. 2017 a las 13:22