Как отфильтровать Single?

Question

[Tsudzukeru]

Есть метод, возвращающий Single>:

@GET("task-m-001/list.php")
    fun getItems(): Single<List<String>>

Внутри списка лежат ссылки на картинки. Некоторые из них битые и picasso их не грузит. Мне нужно как то отфильтровать их. Как это сделать?

Мне нужно превратить Single> в множество Observable, прозвонить ссылку. Если она рабочая то добавить в list, если битая то пропустить.

Пробовал это сделать через flatMap, но чет не получается.

Мой метод выглядит вот так:

fun getItems(){
        _networkState.postValue(NetworkState.LOADING)

        try {
            compositeDisposable.add(
                apiService.getItems()
                    .observeOn(Schedulers.io())
                    .subscribeOn(Schedulers.io())
                    .subscribe({
                        val itemsResponse = itemsResponseConverter.getItemResponse(it)
                        _downloadedItemsResponse.postValue(itemsResponse)
                        _networkState.postValue(NetworkState.LOADED)
                    },
                        {
                            _networkState.postValue(NetworkState.ERROR)
                        })
            )
        }catch (e: Exception) {
            Log.e(TAG, e.message.toString())
        }
    }

Answer 1

[Денис Загаевский]

Не увидел в твоем коде flatMap.
Но вообще будет примерно так

getItems()
.flatMapObservable { items ->
    Observable.fromIterable(items).switchMap { "прозвонить ссылку, что бы это не значило" }
}.toList()

На выходе получится Single<List<String>>

Comments

[Tsudzukeru]

))) Я подразумевал вызвать метод

@GET
    fun checkUrl(@Url url: String):Observable<String>

и если он уйдет в ошибку, то вернуть вместо исходной URL строку "empty_url", по которой конвертером данных я отфильтрую это значение.

Всего 10 ссылок картинок. 2 из них не открываются в браузере, с разными кодами ошибок. Мне и нужно их отфильтровать.

Пробовал сделать как ты ответил, но в итоге приходит пустой List, хотя я прописал onErrorResumeNext().

Что я делаю не так?

fun getItems(){
        _networkState.postValue(NetworkState.LOADING)

        try {
            compositeDisposable.add(
                apiService.getItems()
                    .observeOn(Schedulers.io())
                    .subscribeOn(Schedulers.io())
                    .flatMapObservable { items ->
                        Observable.fromIterable(items)
                            .switchMap {
                                apiService.checkUrl(it)
                                    .observeOn(Schedulers.io())
                                    .subscribeOn(Schedulers.io())
                                    .onErrorResumeNext (Observable.just("empty_url"))
                            }
                    }
                    .toList()
                    .subscribe({ urlList ->
                        Log.i(TAG, "getItems: $urlList")
                        val itemsResponse = itemsResponseConverter.getItemResponse(urlList)
                        _downloadedItemsResponse.postValue(itemsResponse)
                        _networkState.postValue(NetworkState.LOADED)
                    },
                        {
                            Log.i(TAG, "Error - $it")
                            _networkState.postValue(NetworkState.ERROR)
                        })
            )
        }catch (e: Exception) {
            Log.e(TAG, e.message.toString())
        }
    }

вывод в лог - ImageItemsDataSource: getItems: [empty_url]

[Денис Загаевский]

Tsudzukeru, ааа, сорян. Конечно, я по-привычке использовал switchMap, а тебе нужен flatMap вместо него.

[Денис Загаевский]

Tsudzukeru, a что происходит, когда ты ходишь по невалидной ссылке? И какая вообще цель?

[Tsudzukeru]

Денис Загаевский, Некоторые ссылки открывают изображение в браузере, некоторые выдают ошибки 404.

[Денис Загаевский]

Tsudzukeru, ну есть же в клиенте возможность понять, 404 там или 200, в чём проблема?

[Tsudzukeru]

Спасибо!

[Денис Загаевский]

Tsudzukeru, тебе, кстати, надо использовать HEAD запрос, а не GET. Если сервер реализован правильно, то ты узнаешь статус без пересылки всего файла.

[Tsudzukeru]

Денис Загаевский, Денис, по каким источникам ты изучал Rx?

[Денис Загаевский]

Tsudzukeru, да типа прочитал пару статьей вроде Грокаем RxJava. А потом практика в большой команде. Что-то постоянно новое нужно, начинаешь искать пути решения, читаешь доку, пишешь говно, переписываешь на неговно...

[Tsudzukeru]

Денис Загаевский, :)