Skip to content

Instantly share code, notes, and snippets.

@nsk-mironov
Created August 11, 2015 17:33
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save nsk-mironov/0fdc284f5f07df81293b to your computer and use it in GitHub Desktop.
Save nsk-mironov/0fdc284f5f07df81293b to your computer and use it in GitHub Desktop.
public class StackOverflow {
public static void main(String[] args) {
final Observable<Integer> firstObs = Observable.just(1, 2, 3, 4, 5);
final Observable<Integer> secondObs = Observable.just(2, 4, 6);
final Observable<Integer> result = secondObs.toList().flatMap(new Func1<List<Integer>, Observable<Integer>>() {
@Override
public Observable<Integer> call(final List<Integer> ignore) {
return firstObs.filter(new Func1<Integer, Boolean>() {
@Override
public Boolean call(final Integer value) {
return !ignore.contains(value);
}
});
}
});
result.subscribe(new Action1<Integer>() {
@Override
public void call(Integer integer) {
System.out.println("" + integer);
}
});
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment