Skip to content

Instantly share code, notes, and snippets.

Show Gist options
  • Save givemepassxd999/250dd9f1dcf5c625646a512d70938459 to your computer and use it in GitHub Desktop.
Save givemepassxd999/250dd9f1dcf5c625646a512d70938459 to your computer and use it in GitHub Desktop.
Observable.fromIterable(getAlbum())
.flatMap((Function<Album, ObservableSource<Song>>) album -> Observable.fromIterable(album.getSongs()))
.filter(song -> false)
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(s->System.out.println(s.getSongName()));
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment