RxSwift: Return eine neue observable mit einem Fehler

Ich habe eine Funktion, die ein Boolesches Observable, je nachdem, ob es ok war oder nicht.

func test() -> Observable<Bool> {
   if everythingIsOk {
      return just(true)
   }
   return just(false) <- how can i here return a custom error to retrieve what failed?
}
  • return failWith(MyError())
InformationsquelleAutor Godfather | 2015-12-18
  1. 8
    just<E>(element: E) -> Observable<E>

    Gibt eine beobachtbare Sequenz enthält ein einzelnes element.
    Stattdessen sollten Sie so etwas wie, dass:

    create<E>(subscribe: (AnyObserver<E>) -> Disposable) -> Observable<E>

    Create-Methode erstellt eine beobachtbare Sequenz von einer bestimmten subscribe-Methode-Implementierung.

    In Ihrem Fall:

    private let realm = try! Realm()

func save(customObject: CustomObject) -> Observable<Bool> {
    return create({ observer -> Disposable in
        do {
            try self.realm.write {
                self.realm.add(customObject, update: true)
                observer.onNext(true)
                observer.onCompleted()
            }
        } catch {
            //.Error sequence will be automatically completed
            observer.onError(NSError(domai...)
        }

        //if realm.write is sync task(by default it is, as I know) you can actually return NopDisposable
        return NopDisposable.instance
        //otherwise you should cancel write transaction in AnonymousDisposable
    })
}

    AnonymousDisposable ist die Aktion, die aufgerufen wird, in Fall, dass Sie unterbrochen werden. Sagen Sie verlassen Ihre view-controller oder der app getan werden muss, um mit dem service, und Sie brauchen nicht zu nennen, diese Anforderung nicht mehr. Es ist toll für video-uploads oder etwas viel größeres. Sie tun können Anfrage.Abbrechen (), die bereinigt alle Ressourcen, wenn Sie fertig sind mit ihm. Diese wird aufgerufen, die entweder auf die Fertigstellung oder Fehler.

    • Möchte nur hinzufügen, dass meiner Erfahrung nach ist es am besten, um die onNext() etc. außerhalb des try-Blocks. Das Reich schreiben ist nicht wirklich beibehalten werden, bis es vorhanden ist, die Schließung.
    InformationsquelleAutor Alexander Guschin
  2. 2

    Für die Erstellung von observablen es ist create Funktion. Sie können es verwenden, wie diese:

    func test() -> Observable<Bool> {
   return create({ (observer) -> Disposable in
//     Some condition
      observer.onNext(true)
//     Some other condition
      observer.onNext(false)
//     Some other condition
      observer.onError(NSError(domain: "My domain", code: -1, userInfo: nil))
//     Some other condition
      observer.onCompleted()

      return AnonymousDisposable {
//        Dispose resources here
      }
//     If u have nothing to dipose use NopDisposable.instance


   })
}
    • Was ist der Unterschied zwischen Beobachter.onNext(true) Und gerade(true)
    • In deinem einfachen Beispiel gibt es keinen Unterschied, aber in komplexeren, wenn Sie zum Beispiel benötigen, um einige asynchrone Arbeit, wie der Netzwerk-Anfrage oder Holen Sie sich einige Daten aus der Datenbank Sie werden nicht in der Lage, dies zu tun. Und gerade Betreiber nie scheitert es "nur" Beiträge der Wert , mit dem Sie was zu posten
    • Dieses code, wenn die in Ordnung? gist.github.com/anonymous/4619dbfc30c346a63c05
    • Ich bin mir nicht sicher, warum Sie setzen .onCompleted() in den anderen Zustand, der sein soll immer genannt, obwohl es abgeschlossen ist, erfolgreich oder gescheitert ?
    • Die Bedeutung von .onCompleted() dass Sie fertig sind. Ja meine schlecht 🙁 . Auch er wird rufen onComplete Rückrufs, wenn es vorhanden ist, auf Abonnements und (sowie onError) - Aufruf dispose auf Disposable
    InformationsquelleAutor Serg Dort
  3. 0

    Verwenden Sie ein Ergebnis enum als Ihre beobachtbaren Wert.

    public enum Result<Value> {
    case success(Value)
    case failure(Error)
}

func test() -> Observable<Result<Bool>> {
   if everythingIsOk {
      return just(.success(true))
   }

   let error = ...
   return just(.failure(error))
}
    • observablen schicken soll-Werte des angegebenen Typs, oder nicht. mischen der 2 ist eine negative Muster zu observablen Konzept, weil Sie eine Fehlermeldung erhalten, die entweder in der onNext block und die onError block.
    InformationsquelleAutor Tommy Sadiq Hinrichsen
Schreibe einen Kommentar