amit2103
81 lines
2.6 KiB
Java
81 lines
2.6 KiB
Java
package com.baeldung.rxjava;
|
|
|
|
import rx.Observable;
|
|
import rx.observables.BlockingObservable;
|
|
|
|
import java.util.Arrays;
|
|
import java.util.List;
|
|
|
|
public class ObservableImpl {
|
|
|
|
private static Integer[] numbers = {0, 1, 2, 3, 4, 5, 6, 7, 8, 9};
|
|
|
|
private static String[] letters = {"a", "b", "c", "d", "e", "f", "g", "h", "i"};
|
|
private static String[] titles = {"title"};
|
|
private static List<String> titleList = Arrays.asList(titles);
|
|
|
|
static Observable<String> getTitle() {
|
|
return Observable.from(titleList);
|
|
}
|
|
|
|
public static void main(String[] args) {
|
|
|
|
System.out.println("-------Just-----------");
|
|
Observable<String> observable = Observable.just("Hello");
|
|
observable.subscribe(
|
|
System.out::println, //onNext
|
|
Throwable::printStackTrace, //onError
|
|
() -> System.out.println("onCompleted") //onCompleted
|
|
);
|
|
|
|
BlockingObservable<String> blockingObservable = observable.toBlocking();
|
|
|
|
System.out.println();
|
|
System.out.println("-------Map-----------");
|
|
Observable.from(letters)
|
|
.map(String::toUpperCase)
|
|
.subscribe(System.out::print);
|
|
|
|
System.out.println();
|
|
System.out.println("-------FlatMap-----------");
|
|
Observable.just("book1", "book2")
|
|
.flatMap(s -> getTitle())
|
|
.subscribe(System.out::print);
|
|
|
|
System.out.println();
|
|
System.out.println("--------Scan----------");
|
|
Observable.from(letters)
|
|
.scan(new StringBuilder(), StringBuilder::append)
|
|
.subscribe(System.out::println);
|
|
|
|
System.out.println();
|
|
System.out.println("------GroubBy------------");
|
|
Observable.from(numbers)
|
|
.groupBy(i -> 0 == (i % 2) ? "EVEN" : "ODD")
|
|
.subscribe((group) -> group.subscribe((number) -> {
|
|
System.out.println(group.getKey() + " : " + number);
|
|
}));
|
|
|
|
System.out.println();
|
|
System.out.println("-------Filter-----------");
|
|
Observable.from(numbers)
|
|
.filter(i -> (i % 2 == 1))
|
|
.subscribe(System.out::println);
|
|
|
|
System.out.println("------DefaultIfEmpty------------");
|
|
Observable.empty()
|
|
.defaultIfEmpty("Observable is empty")
|
|
.subscribe(System.out::println);
|
|
|
|
System.out.println("------DefaultIfEmpty-2-----------");
|
|
Observable.from(letters)
|
|
.defaultIfEmpty("Observable is empty")
|
|
.first()
|
|
.subscribe(System.out::println);
|
|
|
|
System.out.println("-------TakeWhile-----------");
|
|
Observable.from(numbers)
|
|
.takeWhile(i -> i < 5)
|
|
.subscribe(System.out::println);
|
|
}
|
|
} |