나는 안드로이드에서 RxJava를 배우고 있습니다. 여기이 자습서를 다음입니다 : 아래의 코드와 같이 http://plavatvornica.com/rxjava-for-beginners/우리는 왜 Observer.from()이 필요합니까?
, 난의 OnError
하여 목록에 하나의 항목을 방출이 관측을 만든 나는의 사용의 내 understaning을 deepn하는 질문이 있습니다 RxJava 라이브러리. questio는 목록에서 하나씩 항목을 gt하는 데 RxJava를 사용해야하는 이유는 무엇입니까? 나는 할 수 루프를 사용하여 같은 생각을 !! RxJava 라이브러리는 이러한 기능을 제공하기 때문에 특정 필요성 때문에 계속되어야한다고 생각합니다.
당신은 나를 이해하는 데 도움을 주시기 바랍니다 수 있습니다 그것은
코드
Subscriber listSubscriber = new Subscriber<String>() {
@Override
public void onCompleted() {
Log.i(TAG, "I am done");
}
@Override
public void onError(Throwable e) {
Log.e(TAG, e.getMessage().toString());
}
@Override
public void onNext(String s) {
Log.i(TAG, "onNext: " + s);
}
};
//list as observable
List<String> list = new ArrayList<>();
list.add("1");
list.add("2");
list.add("3");
list.add("4");
Observable myObservable3 = Observable.from(list);
myObservable3.subscribe(listSubscriber);
이 예제는 반응 형 프로그래밍 관용구를 활용하지 않고 라이브러리를 사용하는 방법입니다. –
@ MarkKeen하지만 어떻게 10 명의 옵서버가 같은 결과를 얻을 수 있습니까? AFAIK, 각 옵저버는 단 하나의 가입자 만 있어야합니다. – user2121
여러 구독자가 관찰 할 수있는 .. 내게 합당한 의견을 말합니다. 이해가되지 않는 경우 뜨겁거나 차가운 관찰 대상을 조사하십시오. –