JavaFxObservable.fromObservableList() initial emission

[thomasnield]

The JavaFxObservable.fromObservableList() factory should probably emit the ObservableList on subscription as the initial emission. I'm finding myself putting a startsWith() after it to accomplish this all the time.

[thomasnield]

Anybody who doesn't want the initial emission can just use the skip() operator, and this follows the same behavior for factories applied to ObservableValue.

[thomasnield]

Just implemented this for fromObservableList(), fromObservableMap(), and fromObservableSet(). Closing.

    public static <T> Observable<ObservableList<T>> fromObservableList(final ObservableList<T> source) {

        return Observable.create((Observable.OnSubscribe<ObservableList<T>>) subscriber -> {
            ListChangeListener<T> listener = c -> subscriber.onNext(source);
            source.addListener(listener);
            subscriber.add(JavaFxSubscriptions.unsubscribeInEventDispatchThread(() -> source.removeListener(listener)));
        }).startWith(source).subscribeOn(JavaFxScheduler.getInstance());
    }