Example Analysis of simple Source Code of RxJava

Today, I will talk to you about the example analysis of RxJava simple source code, which may not be well understood by many people. In order to make you understand better, the editor has summarized the following contents for you. I hope you can get something according to this article.

The demo code is as follows

Public class ObservableTest {public static void main (String [] args) {Observable observable = Observable.create (new ObservableOnSubscribe () {@ Override public void subscribe (ObservableEmitter observer) throws Exception {observer.onNext ("the number processed is:" + Math.random () * 100); observer.onComplete ();}}) Observable.subscribe (new Consumer () {@ Override public void accept (Object consumer) throws Exception {System.out.println ("the element I am dealing with is:" + consumer);}});}}

Look at the first line of code first.

Observable observable = Observable.create (new ObservableOnSubscribe () {@ Override public void subscribe (ObservableEmitter observer) throws Exception {observer.onNext ("the number processed is:" + Math.random () * 100); observer.onComplete ();}}); / / Observable.java// line 1560 public static Observable create (ObservableOnSubscribe source) {ObjectHelper.requireNonNull (source, "source is null") / / there are many methods that can be set in RxJavaPlugins. / / similar to Spring's ApplicationListener, return RxJavaPlugins.onAssembly (new ObservableCreate (source)) will be called in the corresponding life cycle;} / / RxJavaPlugins.java// line 1031 public static Observable onAssembly (@ NonNull Observable source) {Function