小编nan*_*lee的帖子

运行我的示例代码后,我期望结果如下.

atest
btest
ctest

但实际上什么都没发生.

请让我知道我的代码有什么问题.

    Subject<String, String> subject = PublishSubject.create();
    subject.onNext("test");

    Observable<String> observable = Observable.from(new String[] {"a", "b", "c"}).repeat(2);
    observable.withLatestFrom(subject, (s1, s2) -> s1 + s2)
            .subscribe(s -> System.out.println(s));