Как объединить с Observable внутри цикла? - PullRequest
Новая
       54

Как объединить с Observable внутри цикла?

0 голосов
/ 12 февраля 2019

Я хотел бы объединить несколько Obserables в один.Я использую метод Observable.mergeWith ().Мое требование - объединиться внутри цикла.Проблема в том, что выбросы не отправляются по подписке.Кажется, проблема в том, как я инициализирую основной Observale, используя Observable<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));
    }
}

1 Ответ

0 голосов
/ 12 февраля 2019

Соберите их как 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();
...