Skip to content

Instantly share code, notes, and snippets.

@alhazmy13 alhazmy13/Example.java
Last active May 9, 2016

Embed
What would you like to do?
RxJava and Retrofit - Example with Github API
package com.company;
import retrofit.RestAdapter;
import retrofit.http.GET;
import retrofit.http.Path;
import rx.Observable;
import rx.Subscriber;
import rx.functions.Action1;
import rx.functions.Func1;
import rx.functions.Func2;
import rx.observables.GroupedObservable;
import java.util.List;
class Repo {
public String full_name;
}
class Contributor {
public String login;
}
interface GitHub {
@GET("/repos/{owner}/{repo}/contributors")
Observable<List<Contributor>> contributors(@Path("owner") String owner, @Path("repo") String repo);
@GET("/users/{user}/starred")
Observable<List<Repo>> starred(@Path("user") String user);
}
public class Main {
public static void main(String[] args) {
RestAdapter restAdapter = new RestAdapter.Builder()
.setEndpoint("https://api.github.com")
.setLogLevel(RestAdapter.LogLevel.FULL)
.setLog(new RestAdapter.Log() {
@Override
public void log(String message) {
System.out.println(message);
}
})
.build();
final GitHub github = restAdapter.create(GitHub.class);
github.contributors("square", "retrofit")
.lift(Main.<Contributor>flattenList())
.flatMap(new Func1<Contributor, Observable<List<Repo>>>() {
@Override
public Observable<List<Repo>> call(Contributor contributor) {
return github.starred(contributor.login);
}
})
.lift(Main.<Repo>flattenList())
.filter(new Func1<Repo, Boolean>() {
@Override
public Boolean call(Repo repo) {
return !repo.full_name.startsWith("square/");
}
})
.groupBy(new Func1<Repo, String>() {
@Override
public String call(Repo repo) {
return repo.full_name;
}
})
.flatMap(new Func1<GroupedObservable<String, Repo>, Observable<String>>() {
@Override
public Observable<String> call(final GroupedObservable<String, Repo> g) {
return g.count().map(new Func1<Integer, String>() {
@Override
public String call(Integer c) {
return c + "\t" + g.getKey();
}
});
}
})
.toSortedList(new Func2<String, String, Integer>() {
@Override
public Integer call(String a, String b) {
return b.compareTo(a);
}
})
.lift(Main.<String>flattenList())
.take(8)
.forEach(new Action1<String>() {
@Override
public void call(String line) {
println(line);
}
});
}
private static void println(String line) {
System.out.println(line);
}
private static <T> Observable.Operator<T, List<T>> flattenList() {
return new Observable.Operator<T, List<T>>() {
@Override
public Subscriber<? super List<T>> call(final Subscriber<? super T> subscriber) {
return new Subscriber<List<T>>() {
@Override
public void onCompleted() {
subscriber.onCompleted();
}
@Override
public void onError(Throwable e) {
subscriber.onError(e);
}
@Override
public void onNext(List<T> contributors) {
for (T c: contributors)
subscriber.onNext(c);
}
};
}
};
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.