но вот пример:
BehaviorSubject<String> s1 = BehaviorSubject.create();
s1.subscribe((s) -> Log.d("app", "s1: " + s));
BehaviorSubject<String> s2 = BehaviorSubject.create();
s2.subscribe((s) -> Log.d("app", "s2: " + s));
s1.onNext("Str1");
s2.onNext("Str2");
BehaviorSubject.combineLatest(s1, s2, (str1, str2) -> {
Log.d("app", "Combined: " + s1 + s2);
return str1 + str2;
});
объясните, пожалуйста, почему не срабатывает combineLatest?
Спасибо.
Мб лучше использовать Observable.combineLatest? А вообще сюда @rxjavachat
Надо подписаться ещё в конце
Обсуждают сегодня