跳转至

RxJava 中可观察的类型

原文:https://www . geesforgeks . org/type-of-observables-in-rxjava/

在模型-视图范例中，这个类代表一个可观察的对象，或者“数据”它可以被子类化，以便表示应用程序希望观察的对象。问题是你正在创建一个软件，这个软件可以在两个维度上呈现描述三维场景的数据。应用程序必须是模块化的，并允许同一场景的大量并发视图。

一个或多个观察者可以被分配给一个可观察的对象。观察者可以是实现观察者界面的任何对象。当可观察的实例发生变化时，调用可观察的 notifyObservers() 方法的应用程序通过调用其更新方法将变化通知给所有的观察者。

图一。RxJava 中的可观察性解释。

简单来说，

  • 可观察的类似于广播该值的扬声器。它执行各种任务并生成一些值。
  • 运算符类似于翻译器，它将数据从一种形式转换/修改为另一种形式。
  • 观察者获取值。

RxJava 中的可观察类型

RxJava 中的许多类型的 Observables 如下:

  • 可观察量
  • 易流动的
  • 单一的
  • 可能
  • 可完成

让我们开始在 RxJava 中创建一些 Observables 来更好地理解这一点，

类型#1:创建基本可观察的

用例:假设你正在下载一个文件，需要推送下载的当前状态。在这种情况下，您必须发出多个值。

我的锅

fun downloadObserervable(): Observable<Int> {
    return Observable.create { gfgshooter ->
        // Declaring an emitter in name of gfgshooter.
        // Beginning the task (in this case a simple download)
        // Your code...
        if (!gfgshooter.isDisposed) {

            // emit the progress
            gfgshooter.onNext(20)
        }
        // Still Downloading
        if (!gfgshooter.isDisposed) {

            // send progress
            gfgshooter.onNext(80)
        }
        // Progress 100, Download Over
        if (!gfgshooter.isDisposed) {

            // send progress
            gfgshooter.onNext(100)

            // send onComplete
            gfgshooter.onComplete()
        }
    }
}

类型#2:使用可观察的创建一个复杂的 Obersever

我的锅

fun getObserver(): Observer<Int> {
    return object : Observer<Int> {
        override fun onStart(d: Disposable) {

            // Observation Started
            // A sample editText
            editText.setText("onStart")
        }
        override fun onNext(progress: Int) {
            // Progress Updated
            editText.setText("onNext : $progress")
        }

        override fun onError(e: Throwable) {
            // Error Thrown
            editText.setText("onError : ${e.message}")
        }

        override fun onComplete() {
            // Observation Complete
            editText.setText("onComplete")
        }
    }
}

观察者<T3】易流动

当“可观察”发出大量观察者无法吸收的值时，“可流动”开始发挥作用。在这种情况下，可观察对象必须根据策略跳过一些数据，否则，它将抛出异常。可流动观察点使用一种策略来处理异常。背压策略为策略，missing 背压异常为异常。

极客提示:就像类型#1 一样，你可以使用 Flowable.create()类似地创建 flow。

孤<T3】单观察者

当可观测值必须只发出一个值时，例如对网络请求的响应，则使用 Single。

类型#3:创建单个可观察

我的锅

fun singleObservable(): Single<String> {
    return Single.create { emitter ->
        // any code which has a task
        if (!gfgEmitter.isDisposed) {
            gfgEmitter.onSuccess("Spandan's Code Ran!")
        }
    }
}

然后以下列方式将其用于单个可观测值:

我的锅

fun singleObservable(): SingleObserver<String> {
    return object : SingleObserver<String> {
        override fun onSubscribe(d: Disposable) {
            edittext.setText("onStart")
        }

        override fun onSuccess(data: String) {
            // Successfully Executed
            editText.setText("onSuccess : $data")
        }

        override fun onError(e: Throwable) {
            // Error or Exception thrown.
           editText.setText("onError : ${e.message}")
        }
    }
}

T1【也许】T3>观察者

当可观测值必须发出一个值或没有值时，可能使用。

类型#4:创建一个可能的观察者

我的锅

fun maybeObservable(): Maybe<String> {
    return Maybe.create { gfgemitter ->
        // your code goes here
        if (!gfgemitter.isDisposed) {
            gfgemitter.onSuccess("Spandan's Code!")
        }
    }
}
回到顶部