File tree Expand file tree Collapse file tree 1 file changed +29
-0
lines changed
rxjava-core/src/test/java/rx Expand file tree Collapse file tree 1 file changed +29
-0
lines changed Original file line number Diff line number Diff line change 19
19
20
20
import org .junit .Test ;
21
21
22
+ import rx .Observable .Transformer ;
22
23
import rx .functions .Func2 ;
23
24
24
25
/**
@@ -57,6 +58,34 @@ public Integer call(Media t1, Media t2) {
57
58
o2 .toSortedList (SORT_FUNCTION );
58
59
}
59
60
61
+
62
+ @ Test
63
+ public void testCovarianceOfCompose () {
64
+ Observable <HorrorMovie > movie = Observable .<HorrorMovie > from (new HorrorMovie ());
65
+ movie .compose (new Transformer <Movie , Movie >() {
66
+
67
+ @ Override
68
+ public Observable <Movie > call (Observable <Movie > t1 ) {
69
+ return Observable .from (new Movie ());
70
+ }
71
+
72
+ });
73
+ }
74
+
75
+ @ Test
76
+ public void testCovarianceOfCompose2 () {
77
+ Observable <Movie > movie = Observable .<Movie > from (new HorrorMovie ());
78
+ movie .compose (new Transformer <Movie , Movie >() {
79
+
80
+ @ Override
81
+ public Observable <Movie > call (Observable <Movie > t1 ) {
82
+ return Observable .from (new HorrorMovie ());
83
+ }
84
+
85
+ });
86
+ }
87
+
88
+
60
89
/*
61
90
* Most tests are moved into their applicable classes such as [Operator]Tests.java
62
91
*/
You can’t perform that action at this time.
0 commit comments