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 3639e73 commit f2591cbCopy full SHA for f2591cb
src/main/java/rx/internal/operators/OperatorSequenceEqual.java
@@ -35,15 +35,7 @@ private OperatorSequenceEqual() {
35
}
36
37
static <T> Observable<Object> materializeLite(Observable<T> source) {
38
- return concat(
39
- source.map(new Func1<T, Object>() {
40
-
41
- @Override
42
- public Object call(T t1) {
43
- return t1;
44
- }
45
46
- }), just(LOCAL_ONCOMPLETED));
+ return concat(source, just(LOCAL_ONCOMPLETED));
47
48
49
/**
0 commit comments