mergeMap/flatMap and Java 8 type inference

[benjchristensen]

@adelnizamutdinov I don't see a new issue created, so wanted to pick it up here.

You said this:

mergeMap is almost unusable with Java 8 type inference
Always have to extend Observable::just and Observable::empty to anonymous classes

Can you elaborate?

[benjchristensen]

        Observable.from(1, 2, 3, 4).mergeMap(i -> {
            if (i < 3) {
                return Observable.just("value_" + i);
            } else {
                return Observable.empty();
            }
        }).forEach(System.out::println);

[benjchristensen]

It also correctly infers it is a String:

        Observable<String> mergeMap = Observable.from(1, 2, 3, 4).mergeMap(i -> {
            if (i < 3) {
                return Observable.just("value_" + i);
            } else {
                return Observable.empty();
            }
        });

[meoyawn]

@benjchristensen
here's the example that won't compile because of the variance/contravariance and java 8 lambda's type inference:

static class User {
    String name;
    int age;

    User(String name, int age) {
        this.name = name;
        this.age = age;
    }
}

public static void main(String[] args) {
    savedUser()
            .mergeMap(Observable::just, e -> fetchUser(), Observable::empty)
            .forEach(user -> System.out.println(user.name));
}

static Observable<User> savedUser() {
    return Observable.error(new IllegalStateException("there are no saved users"));
}

static Observable<User> fetchUser() {
    return Observable.just(new User("Adel", 13));
}

[benjchristensen]

This code compiles and runs for me:

import rx.Observable;


public class Issue1550 {

    static class User {
        String name;
        int age;

        User(String name, int age) {
            this.name = name;
            this.age = age;
        }
    }

    public static void main(String[] args) {
        savedUser()
                .mergeMap(Observable::just, e -> fetchUser(), Observable::empty)
                .forEach(user -> System.out.println(user.name));
    }

    static Observable<User> savedUser() {
        return Observable.error(new IllegalStateException("there are no saved users"));
    }

    static Observable<User> fetchUser() {
        return Observable.just(new User("Adel", 13));
    }

}

It outputs:

Adel

[benjchristensen]

Ah interesting, it works in Eclipse, but not from command line.

lgml-bechristensen:libs benjchristensen$ /Library/Java/JavaVirtualMachines/jdk1.8.0_0.jdk/Contents/Home/bin/javac -cp rxjava-core-0.20.0-RC4-SNAPSHOT.jar Issue1550.java 
Issue1550.java:18: error: incompatible types: no instance(s) of type variable(s) T#1 exist so that Observable<T#1> conforms to ? extends Observable<? extends R>
                .mergeMap(Observable::just, e -> fetchUser(), Observable::empty)
                         ^
  where T#1,R,T#2 are type-variables:
    T#1 extends Object declared in method <T#1>empty()
    R extends Object declared in method <R>mergeMap(Func1<? super T#2,? extends Observable<? extends R>>,Func1<? super Throwable,? extends Observable<? extends R>>,Func0<? extends Observable<? extends R>>)
    T#2 extends Object declared in class Observable
1 error

[benjchristensen]

I believe this is now fixed as of #1558.

If you can confirm against the branch, please do. Reopen if there are still issues.

[meoyawn]

@benjchristensen I don't have the rights to reopen the issues
but I cloned the master, built the jar and tried to compile:

$JAVA8_HOME/bin/javac Test.java -cp rxjava-core-0.20.0-RC5-SNAPSHOT.jar
Test.java:19: error: incompatible types: no instance(s) of type variable(s) T#1 exist so that Observable<T#1> conforms to ? extends Observable<? extends R>
                .mergeMap(Observable::just, e -> fetchUser(), Observable::empty)
                         ^
  where T#1,R,T#2 are type-variables:
    T#1 extends Object declared in method <T#1>empty()
    R extends Object declared in method <R>mergeMap(Func1<? super T#2,? extends Observable<? extends R>>,Func1<? super Throwable,? extends Observable<? extends R>>,Func0<? extends Observable<? extends R>>)
    T#2 extends Object declared in class Observable

I don't really think this is an issue, because expanding the method ref as a new Func1... works just fine, but is ugly in java8
so I thought maybe it's me who's doing something wrong
I am very bad with co- and contravariance so I can't even figure out how to change mergeMap's signature so that the thing compiles with method references

[meoyawn]

@benjchristensen I'm using Oracle JDK on Ubuntu 14.04

$JAVA8_HOME/bin/javac -version
javac 1.8.0_11

[benjchristensen]

@zsxwing You're good at figuring this kind of stuff out, so is there anything we should be doing differently here, or is this just a weakness of Java 8?