建设一个网站平台的费用,长沙市公共资源交易中心,绩溪网站建设,网站开发设计项目书案例代码#xff1a;https://gitee.com/bobidali/lite-rx-java/commit/292e9227a5491f7ec6a07f395292ef8e6ff69290
RxJava 的调用第一步是封装了观察者接受了数据的处理#xff0c;进一步就是使用 map 将数据操作传递给上下游
1、类似Observer.create 创建一个简单的观察者…案例代码https://gitee.com/bobidali/lite-rx-java/commit/292e9227a5491f7ec6a07f395292ef8e6ff69290
RxJava 的调用第一步是封装了观察者接受了数据的处理进一步就是使用 map 将数据操作传递给上下游
1、类似Observer.create 创建一个简单的观察者
abstract class SingleT : SingleSourceT {companion object {JvmStaticfun T just(item: T): SingleT {return RxJavaPlugins.onAssembly(SingleJust(item))}}override fun subscribe(observer: SingleObserverin T) {Objects.requireNonNull(observer, observer is null)try {var obsv observerobsv RxJavaPlugins.onSubscribe(this, obsv)subscribeActual(obsv)} catch (e: NullPointerException) {throw e} catch (e: Throwable) {throw NullPointerException(subscribeActual failed).initCause(e)}}protected abstract fun subscribeActual(observer: SingleObserverin T)
}class SingleJustT(private val value: T) : SingleT() {override fun subscribeActual(observer: SingleObserverin T) {observer.onSubscribe(Disposable.disposed())observer.onSuccess(value)}
}2、在SingleObserver 中加入map 方法实现数据的承上启下 fun R map(mapper: com.example.literj.kt.internal.functions.Functionin T, out R): SingleR {Objects.requireNonNull(mapper, mapper is null)return RxJavaPlugins.onAssembly(SingleMap(this, mapper))}class SingleMapT, R(private val source: SingleSourceout T,private val mapper: Functionin T, out R
) : SingleR() {override fun subscribeActual(observer: SingleObserverin R) {source.subscribe(MapSingleObserver(observer, mapper))}internal class MapSingleObserverT, R(private val t: SingleObserverin R,private val mapper: Functionin T, out R) : SingleObserverT {override fun onSuccess(t: T) {val v: Rtry {v Objects.requireNonNull(mapper.apply(t),The mapper function returned a null value.)} catch (e: Throwable) {onError(e)return}this.t.onSuccess(v)}override fun onSubscribe(d: Disposable) {t.onSubscribe(d)}override fun onError(e: Throwable) {t.onError(e)}}
}3、铛铛完成看看调用案例 public static void sample3() {String tag sample3;Log.d(TAG tag, start);Single.just(777).map(data1 - 777).map(data2 - 888).subscribe(getSingleObserver(tag));}2023-08-13 11:58:23.703 21522-21522/com.example.literj D/RxJavaTestUtil sample3: start
2023-08-13 11:58:23.713 21522-21522/com.example.literj D/RxJavaTestUtil sample3: onSubscribe
2023-08-13 11:58:23.713 21522-21522/com.example.literj D/RxJavaTestUtil sample3: onSuccess 888ok那么下一篇就加入线程切换
