have CompositeObservable#addAll() return a CompositeSubscription instead

Author: thomasnield

src/main/java/rx/javafx/sources/CompositeObservable.java

@@ -20,6 +20,7 @@
 import rx.annotations.Beta;
 import rx.subjects.PublishSubject;
 import rx.subjects.SerializedSubject;
+import rx.subscriptions.CompositeSubscription;
 
 import java.util.Arrays;
 import java.util.List;
@@ -75,7 +76,9 @@ public Observable<T> toObservable() {
     public Subscription add(Observable<T> observable) {
         return observable.subscribe(subject);
     }
-    public List<Subscription> addAll(Observable<T>... observables) {
-        return Arrays.stream(observables).map(this::add).collect(Collectors.toList());
+    public CompositeSubscription addAll(Observable<T>... observables) {
+        final CompositeSubscription subscriptions = new CompositeSubscription();
+        Arrays.stream(observables).map(this::add).forEach(subscriptions::add);
+        return subscriptions;
     }
 }