So I finally figured out my problem (For real this...

# rx

[blakelee]

So I finally figured out my problem (For real this time). But a new problem came up. I am calling an api which will return a list of 30 items. I do some stuff on those items and then watch for it. However, I'm getting 30 lists of 30 items 😕

fun getUsers(since: Int): Observable<MutableList<User>> =
        api.getUsers(since)
                .subscribeOn(<http://Schedulers.io|Schedulers.io>())
                .flatMap { items -> Observable.fromIterable(items).map(this::getUserByLogin) }
                .toList()
                .toObservable()
                .doOnError(this::failedUser)
                .observeOn(AndroidSchedulers.mainThread())