Привет! Помогите, сломал голову на этом rx. В целом всё понятно,

Question

Привет! Помогите, сломал голову на этом rx. В целом всё понятно,

но вот пример:
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?
Спасибо.