반응형
공감 및 댓글은 포스팅 하는데 아주아주 큰 힘이 됩니다!! 포스팅 내용이 찾아주신 분들께 도움이 되길 바라며 더 깔끔하고 좋은 포스팅을 만들어 나가겠습니다^^
|
이번 포스티에서는 Observable의 특수한 형태은 Single 클래스에 대해 공부합니다.
Single
Observable은 데이터를 제한 없이 발행할 수 있지만,
Single 의 경우는 데이터를 오직 한 개만 발행하도록 제한합니다.
일반적으로 결과가 유일한 서버 API를 호출할 때 유용하게 사용할 수 있습니다.
Observable 처럼 just() 함수를 호출합니다.
1 2 3 4 5 6 7 8 9 10 | import io.reactivex.Single; public class SingleClass { public static void main(String[] args) { Single<String> single = Single.just("Hello world!"); single.subscribe(System.out::println); } } | cs |
그리고 Single은 Observable의 특수한 형태이기 때문에,
Observable 에서 Single로 변환할 수 있습니다.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 | import io.reactivex.Observable; import io.reactivex.Single; public class SingleClass { public static void main(String[] args) { // Observable -> Single Observable<String> src1 = Observable.just("Hello world"); Single.fromObservable(src1).subscribe(System.out::println); System.out.println("===================="); Observable.just("Hello world") .single("Hi world") .subscribe(System.out::println); System.out.println("===================="); // 배열을 받지만, first함수를 통해 첫 번째 값만을 발행 String[] names = {"Thomas", "Tom", "Tommy"}; Observable.fromArray(names) .first("TTT") .subscribe(System.out::println); System.out.println("===================="); //빈 Observable에서 Single 객체 생성 Observable.empty() .single("Hello world") .subscribe(System.out::println); System.out.println("===================="); //take 함수를 사용해 Single 객체 생성 Observable.just(new Custom("Hello world"), new Custom("Hi world")) .take(1) .single(new Custom("What's up world")) .subscribe(System.out::println); } } | cs |
take 에제에서 사용된 Custom클래스입니다.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 | public class Custom { private String print; public Custom(String print) { super(); this.print = print; } public String getPrint() { return print; } @Override public String toString() { return "Output : " + print; } } | cs |
Maybe
RxJava2 에서 새롭게 도입된 Observable의 특수한 형태입니다.
'아마도' 라는 뜻인데요.
Single과 마찬가지로 최대 한 개의 데이터를 가질 수 있지만,
데이터의 발행 없이 바로 데이터 발생을 완료할 수 있습니다.
Maybe = Single + onComplete() 라고 할 수 있습니다.
자세한 내용은 후에 공부하도록 하겠습니다.
이상입니다. 감사합니다.
반응형