rx-java - 如何与 Observable 内部循环合并？

Question

我想将几个 Obserable 合并为一个。我使用 Observable.mergeWith() 方法。我的要求是在循环内合并。问题是订阅时没有发送排放。问题似乎是我使用初始化主要 ObservaleObservable<String> observable = Observable.never();的方式，但我没有找到正确的方法（尝试PublishSubject.create();过Observable.empty();）

import io.reactivex.Observable;
import io.reactivex.rxjavafx.observables.JavaFxObservable;
import javafx.application.Application;
import javafx.scene.Scene;
import javafx.scene.control.Button;
import javafx.scene.layout.VBox;
import javafx.stage.Stage;

public class NeverApplication extends Application {

    public static void main(String[] args) {
        launch(args);
    }

    @Override
    public void start(Stage stage) throws Exception {

        Observable<String> observable = Observable.never();

        VBox vBox = new VBox();

        for (int i = 0; i < 4; i++) {
            Button button = new Button("Button " + i);
            vBox.getChildren().add(button);
            Observable<String> clickedObservale = JavaFxObservable.actionEventsOf(button).map(event -> button.getText());
            observable.mergeWith(clickedObservale);
        }

        stage.setScene(new Scene(vBox));
        stage.show();

        observable.subscribe(next -> System.out.println(next));
    }
}

Answer 1

最好将它们收集为Iterable简单的List，并使用静态方法Observable.merge

List<Observable<String>> observables = new ArrayList<>();
observables.add(Observable.never());
for (int i = 0; i < 4; i++) {
    observables.add(...);
}

Observable.merge(observables).subscribe();