update

Author: yennanliu

dev_projects/RxJava/RxJava/src/main/java/com/yen/courseV1/part1.java

@@ -7,6 +7,7 @@
 public class part1 {
     public static void main(String[] args){
 
+        // Observable.create
         Observable<String> observable = Observable.create(emitter -> {
             emitter.onNext("click on 1");
             emitter.onNext("click on 2");

dev_projects/RxJava/RxJava/src/main/java/com/yen/courseV1/part2.java

@@ -2,8 +2,68 @@
 
 // https://youtu.be/ApUUN55V2RE?si=zOpzZ14He9IzmqGZ
 
+import rx.Observable;
+import rx.Observer;
+
+import java.util.ArrayList;
+import java.util.List;
+
 public class part2 {
   public static void main(String[] args) {
 
+      /** Example 1 */
+      // Observable via just
+      Observable<String> observable = Observable.just("item 1", "item 2");
+
+      List<Integer> numbers = new ArrayList<>();
+      numbers.add(1);
+      numbers.add(2);
+
+      // implement Observer
+      Observer<String> observer = new Observer<String>() {
+          @Override
+          public void onCompleted() {
+              System.out.println("On Completed called !");
+          }
+
+          @Override
+          public void onError(Throwable throwable) {
+
+          }
+
+          @Override
+          public void onNext(String s) {
+              System.out.println("onNext -- " + s);
+          }
+      };
+
+      // run
+      observable.subscribe(observer);
+
+      /** Example 2 */
+
+      // Observable from iterable
+      Observable<Integer> observable2 = Observable.from(numbers);
+
+      Observer<Integer> observer2 = new Observer<Integer>() {
+          @Override
+          public void onCompleted() {
+              System.out.println("On Completed called !");
+          }
+
+          @Override
+          public void onError(Throwable throwable) {
+
+          }
+
+          @Override
+          public void onNext(Integer integer) {
+              System.out.println("onNext -- " + integer);
+          }
+      };
+
+      // run
+      observable2.subscribe(observer2);
   }
+
 }

dev_projects/RxJava/progress.txt

@@ -1,4 +1,6 @@
 # Progress
 
 ## 20240719
-- https://www.youtube.com/watch?v=7mbjhNCWqvs&list=PLZ3FH0lcV0117kiek3g-qiQDkO4ezy_Ro
+- https://youtu.be/7mbjhNCWqvs?si=GtCY3Wk5AFTdjYgS
+- https://youtu.be/ApUUN55V2RE?si=zOpzZ14He9IzmqGZ
+- https://youtu.be/ApUUN55V2RE?si=ZpZ6K7coesyXk3nO