We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 02d320e commit 4c59538Copy full SHA for 4c59538
src/main/java/rx/javafx/sources/ObservableSetSource.java
@@ -13,6 +13,7 @@ public static <T> Observable<ObservableSet<T>> fromObservableSet(final Observabl
13
14
return Observable.create((Observable.OnSubscribe<ObservableSet<T>>) subscriber -> {
15
SetChangeListener<T> listener = c -> subscriber.onNext(source);
16
+ source.addListener(listener);
17
subscriber.add(JavaFxSubscriptions.unsubscribeInEventDispatchThread(() -> source.removeListener(listener)));
18
}).startWith(source).subscribeOn(JavaFxScheduler.getInstance());
19
}
0 commit comments