Android-使用 RxJava2 封装 RxBus

冷不防 2022-12-11 13:56 190阅读 0赞

# 实现 #

> 内容来源网络，链接忘记了，侵权删。

object RxBus { 
        private val TAG = javaClass.simpleName
    
        /** * 用于保存RxBus事件的所有订阅，并在需要时正确的取消订阅。 */
        private val disposablesMap: HashMap<Any, CompositeDisposable?> by lazy { 
            HashMap<Any, CompositeDisposable?>()
        }
    
        /** * 避免直接使用此属性，因为它仅在内联函数中使用而暴露 * PublishSubject：接收到订阅之后的所有数据 * ReplaySubject：接收到所有的数据，包括订阅之前的所有数据和订阅之后的所有数据。 * BehaviorSubject：接收到订阅前的最后一条数据和订阅后的所有数据。 * AsyncSubject：不管在什么位置订阅，都只接收到最后一条数据 */
        val rxBus = PublishSubject.create<Any>().toSerialized()
    
    
        /** * 向RxBus发送一个事件，这个事件可以来自任意一个线程 */
        fun send(event: Any) { 
            rxBus.onNext(event)
        }
    
        /** * 订阅特定类型T的事件。可以从任何线程调用 */
        inline fun <reified T : Any> observe(): Observable<T> { 
            return rxBus.ofType(T::class.java)
        }
    
        /** * 从RxBus事件中取消注册订阅者 * 调用订阅的取消订阅方法 */
        fun unRegister(disposable: Any) { 
            val compositeDisposable = disposablesMap[disposable]
            if (compositeDisposable == null) { 
                Log.e(TAG, "compositeDisposable == null")
            } else { 
                compositeDisposable.clear()
                disposablesMap.remove(disposable)
            }
        }
    
        /** * internal修饰符 只有在相同模块中才能使用 */
        internal fun register(disposable: Any, composite: Disposable) { 
            var compositeDisposable = disposablesMap[disposable]
            if (compositeDisposable == null) { 
                compositeDisposable = CompositeDisposable()
            }
            compositeDisposable.add(composite)
            disposablesMap[disposable] = compositeDisposable
        }
    }
    
    /** * 注册订阅以便以后正确注销它以避免内存泄漏 * @param disposable 拥有此订阅的订阅对象 */
    fun Disposable.registerInBus(disposable: Any) { 
        RxBus.register(disposable, this)
    }
    
    
    使用：
    1. 注册，在 onCreate 方法
    RxBus.observe<String>()
                .subscribe {  t: String? ->
                   Log.e(TAG,"接收的数据：$t")
                }
                .registerInBus(this)
    
    2. 发送
    RxBus.send("123")
    
    3. 注销，在 onDestory 方法
    RxBus.unRegister(this)