[RxJava] Observable - (2)

💁단일 데이터가 아닌 경우는 어떻게 할까요,
앞서 공부한 just()나 create()는 단일 데이터를 주로 다루어 보았는데요. 이번에는 단일 데이터가 아닐 경우에 어떻게 사용하는지

즉 fromXXX() 계열 함수에 대해 알아보도록 하겠습니다.

---

fromArray() 함수

Integer[] arr = {100,200,300};
Observable<Integer> source = Observable.fromArray(arr);
source.subscribe(System.out::println);

🎈int [] 배열 사용하기

int[] 배열을 실제로 그대로 넣으면 올바른 실행결과가 나오지 않습니다. ⇒ toIntegerArray()를 사용해야 합니다.

 

int[] intArray = {400,500,600};
Observable<Integer> source = Observable.fromArray(toIntegerArray(intArray));
source.subscribe(System.out::println);

 

 

fromIterable() 함수

• Iterable 인터페이스는 반복자를 반환합니다.
• Iterator 인터페이스는 이터레이터 패턴을 구현한 것으로 다음에 어떤 데이터가 있는지와 그 값을 얻어오는 것만 관여할 뿐 특정 데이터 타입에 의존하지 않습니다.
• hasNext()와 next() 메서드가 존재합니다.
• 대표적인 클래스 : ArrayList, ArrayBlockingQueue, HashSet, LinkedList, Stack, TreeSet, Vector 등이 존재합니다.

List<String> names = new ArrayList<>();
names.add("Jerry")
names.add("William")
names.add("Bob")

Observable<String> source = Observable.fromIterable(names);
source.subscribe(System.out::println)

 

fromCallable() 함수 :  비동기 클래스나 인터페이스와의 연동

Callable<String> callable = () -> {
	Thread.sleep(1000);
	return "Hello Callable";
};

Observable<String> source = Observable.fromCallable(callable);
source.subscribe(System.out::println);

*Callable은 실행 결과를 리턴하고 Executor 인터페이스의 인자로 활용되기 때문에 잠재적으로 다른 스레드에서 실행되는 것을 의미합니다.

 

fromFuture() 함수

• Future은 동시성 API로 비동기 계산의 결과를 구할 때 사용합니다.
• 보통 Executor 인터페이스를 구현한 클래스에 Callable 객체를 인자로 넣어 Future 객체 반환합니다.

Future<String> future = Executors.newSingleThreadExecutor().submit(() -> {
	Thread.sleep(1000);
	return "Hello Future";
});
Observable<String> source = Observable.fromFuture(future);
source.subscribe(System.out::println);

 

 

fromPublisher() 함수

Publisher<String> publisher = (Subscriber<? super String> s) -> {
	s.onNext("hello Observable.fromPublisher()");
	s.onComplete();
};
Observable<String> source = Observable.fromPublisher(publisher)
source.subscribe(System.out::println);

*Publisher 인터페이스의 패키지는 org.reactivestreams