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 558da22 commit d25a152Copy full SHA for d25a152
src/main/java/rx/javafx/sources/CompositeObservable.java
@@ -22,6 +22,8 @@
22
import rx.subjects.SerializedSubject;
23
24
import java.util.Arrays;
25
+import java.util.List;
26
+import java.util.stream.Collectors;
27
28
29
/**
@@ -73,7 +75,7 @@ public Observable<T> toObservable() {
73
75
public Subscription add(Observable<T> observable) {
74
76
return observable.subscribe(subject);
77
}
- public void addAll(Observable<T>... observables) {
- Arrays.stream(observables).forEach(this::add);
78
+ public List<Subscription> addAll(Observable<T>... observables) {
79
+ return Arrays.stream(observables).map(this::add).collect(Collectors.toList());
80
81
0 commit comments