Programming VIP

Transformer purpose Transformer, as the name suggests, means converter. As early as rxjava 1 The X version has Observable Transformer,Single.Transformer and complete Transformer, in 2 In version x, it becomes Observable transformer, SingleTransformer, completable transformer, Flowable transformer and maybtransformer. Among them, FlowableTransf ...

usage method Let's start with the most basic use: Observable.create(new ObservableOnSubscribe<String>() { @Override public void subscribe(ObservableEmitter<String> emitter) throws Exception { emitter.onNext("1"); emitter.onNext("2"); emitter.onNext("3" ...

1. Problem scenario In practical work, we often need to share data between different objects and different modules, and these data are usually changeable, so a problem may occur: when the data changes, the relevant objects or modules do not know and do not update the data in time. At this time, we hope to notify other modules to update synchro ...

Create type operator The creation operator is used to create an Observable object, Observable subject object and pop up data. RxJava has many creation operators, which are roughly as follows: (1) Create (): create an Observable topic object from scratch using the function. (2) defer(): Observable topic objects are created only when subscribe ...

Lack of LiveData LiveData is an observable data storage class dedicated to Android with autonomous life cycle awareness. It is deliberately simplified in design, which makes it easy for developers to start, but its shortcomings are as follows: LiveData can only update data in the main thread (the underlying layer of postValue is also switched ...

summary The source code of rxjava simple subscribe has been mentioned earlier. Interested readers can have a look. Rxjava source code analysis (I) - subscribe source code Based on the previous analysis, this article will continue to talk about rxjava interrupt thread switching. Demo The main logic is as follows: Observable calls create() t ...