Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- ConnectionService matchesService = ServiceGenerator.createService(ConnectionService.class, configurationManager.getAccessToken());
- final List<Match> matches = new ArrayList<>();
- Observable<Matches> matchesObservable = matchesService.getMatch(getDate(month, year));
- matchesObservable.subscribeOn(Schedulers.newThread())
- .observeOn(AndroidSchedulers.mainThread())
- .flatMap(new Func1<Matches, Observable<Match>>() {
- @Override
- public Observable<Match> call(Matches matches) {
- return Observable.from(matches.getEmbedded().getMatchList());
- }
- })
- .filter(new Func1<Match, Boolean>() {
- @Override
- public Boolean call(Match match) {
- return !match.getVideos().isEmpty();
- }
- })
- .subscribe(new Subscriber<Match>() {
- @Override
- public void onCompleted() {
- Log.d(TAG, "widjoz zajz =" + matches.size());
- }
- @Override
- public void onError(Throwable e) {
- Log.e(TAG, e.toString());
- }
- @Override
- public void onNext(Match match) {
- matches.add(match);
- }
- });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement