Temp-1

1. Print Primptive & Non-Primptive Data Type - Using Flowable, Observable
--------------------------------------------------------------------
A. Observable

Observable.just("one", "two", "three")
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(value -> textView.append(value+", "));

B. Flowable 

Flowable.just("one", "two", "three")
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(value -> textView.append(value+", "));

C. CompletableToFlowable 

CompletableToFlowable.just("one", "two", "three")
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(value -> textView.append(value+", "));

----------------------------------------------------------------------


2. Print collection - Using Flowable, Observable
--------------------------------------------------------------------

List<String> list = new ArrayList<>();
list.add("One");
list.add("Two");
list.add("Three");
list.add("Four");

A. Observable

Observable.just(list)
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(value -> textView.append(value+", "));

B. Flowable 

Flowable.just(list)
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(value -> textView.append(value+", "));

C. CompletableToFlowable 

CompletableToFlowable.just(list)
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(value -> textView.append(value+", "));



----------------------------------------------------------------------


3. Observer instead of AsyncTask
--------------------------------------------------------------------
Calling Method

myObserver.onSubscribe(d);
myObserver.onNext("Do Something Here!");

Implementation

   Observer<String> myObserver = new Observer<String>() {
        @Override
        public void onSubscribe(Disposable d) {
            textView.append("\n onSubscribe() - Start Progress");
        }

        @Override
        public void onNext(String s) {
            textView.append("\n onNext() - "+s);
            myObserver.onComplete();
        }

        @Override
        public void onError(Throwable e) {
            textView.append("\n onError() - "+e.getMessage());
        }

        @Override
        public void onComplete() {
            textView.append("\n onComplete() - Stop Progress");

            Throwable throwable = new Throwable("Error found");
            myObserver.onError(throwable);
        }
    };

----------------------------------------------------------------------


4.
--------------------------------------------------------------------

----------------------------------------------------------------------


1.
--------------------------------------------------------------------

----------------------------------------------------------------------


1.
--------------------------------------------------------------------

----------------------------------------------------------------------


1.
--------------------------------------------------------------------

----------------------------------------------------------------------


1.
--------------------------------------------------------------------

----------------------------------------------------------------------


1.
--------------------------------------------------------------------

----------------------------------------------------------------------


1.
--------------------------------------------------------------------

----------------------------------------------------------------------

















22