@@ -5,7 +5,11 @@ import rx.Observer
5
5
import rx.Observable
6
6
7
7
public fun <T > Function1 <Observer <in T >, Subscription>.asObservable (): Observable <T > {
8
- return Observable .create{ this (it!! ) }!!
8
+ return Observable .create { this (it!! ) }!!
9
+ }
10
+
11
+ public fun <T > Function0 <Observable <out T >>.defer (): Observable <T > {
12
+ return Observable .defer(this )!!
9
13
}
10
14
11
15
public fun <T > Iterable<T>.asObservable (): Observable <T > {
@@ -15,3 +19,31 @@ public fun<T> Iterable<T>.asObservable(): Observable<T> {
15
19
public fun <T > T.asObservable (): Observable <T > {
16
20
return Observable .from(this )!!
17
21
}
22
+
23
+ public fun <T > Throwable.asObservable (): Observable <T > {
24
+ return Observable .error(this )!!
25
+ }
26
+
27
+ public fun <T > Pair <T , T >.asObservable (): Observable <T > {
28
+ return Observable .from(this .component1(), this .component2())!!
29
+ }
30
+
31
+ public fun <T > Triple <T , T , T >.asObservable (): Observable <T > {
32
+ return Observable .from(this .component1(), this .component2(), this .component3())!!
33
+ }
34
+
35
+ public fun <T > Pair <Observable <T >, Observable<T>>.merge (): Observable <T > {
36
+ return Observable .merge(this .component1(), this .component2())!!
37
+ }
38
+
39
+ public fun <T > Triple <Observable <T >, Observable <T >, Observable<T>>.merge (): Observable <T > {
40
+ return Observable .merge(this .component1(), this .component2(), this .component3())!!
41
+ }
42
+
43
+ public fun <T > Pair <Observable <T >, Observable<T>>.mergeDelayError (): Observable <T > {
44
+ return Observable .mergeDelayError(this .component1(), this .component2())!!
45
+ }
46
+
47
+ public fun <T > Triple <Observable <T >, Observable <T >, Observable<T>>.mergeDelayError (): Observable <T > {
48
+ return Observable .mergeDelayError(this .component1(), this .component2(), this .component3())!!
49
+ }
0 commit comments