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 fb28c7b commit 3bd9e78Copy full SHA for 3bd9e78
src/main/java/rx/javafx/sources/ObservableSetSource.java
@@ -12,7 +12,6 @@ private ObservableSetSource() {}
12
public static <T> Observable<ObservableSet<T>> fromObservableSet(final ObservableSet<T> source) {
13
14
return Observable.create((Observable.OnSubscribe<ObservableSet<T>>) subscriber -> {
15
- subscriber.onNext(source);
16
SetChangeListener<T> listener = c -> subscriber.onNext(source);
17
subscriber.add(JavaFxSubscriptions.unsubscribeInEventDispatchThread(() -> source.removeListener(listener)));
18
}).startWith(source).subscribeOn(JavaFxScheduler.getInstance());
0 commit comments