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

Спасибо!

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

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

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

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

@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]

Как получить POJO из JsonArray?

illuzor, Сделал вот такой Rx метод

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

и конвертер, который List конвертит в Response класс.
Так работает, но я не уверен, что это правильно.

Как получить POJO из JsonArray?

О нем знаю, но если туда кинуть вот такой Json - ["a","b","c"] - ничего не генерится.

Как передать переменную в DAG, используя новый API Dagger 2?

Нет, имел ввиду dagger.android

Нужно ли делать DI для простых Kotlin объектов?

Денис, а если DI только усложняет код? Например у меня есть фргмент с RecyclerView.
Этот RecyclerView я инициализирую с помощью findViewById(), но так же мне нужно для него создать адаптер.

Адаптер можно внедрить, а можно создать руками.
Внутри адаптера нужно хранить ссылку на viewModel, чтобы дергать ее методы. Получается мне нужно инджектить ViewModel в Adapter, если я буду делать DI адаптера в фрагмент. А раз так, то нужно так же передавать ссылку на фрагмент. Получается примерно вот такой код:

@PreviewScope
class MediaPreviewAdapter @Inject constructor(
    val providerFactory: ViewModelProviderFactory,
    val picasso: Picasso,
    val searchParams: SearchParams,
    val previewFragment: PreviewMediaFragment
) :
    RecyclerView.Adapter<RecyclerView.ViewHolder>() {

    val viewModel =
        ViewModelProviders.of(previewFragment, providerFactory)
            .get(PreviewMediaViewModel::class.java)

...

}

Ну и компонент выглядит вот так:

@PreviewScope
@Subcomponent(modules = [ViewModelFactoryModule::class, PreviewMediaViewModulesModule::class, PreviewModule::class])
interface PreviewComponent {

    @Subcomponent.Factory
    interface Factory {
        fun create(@BindsInstance fragment: PreviewMediaFragment): PreviewComponent
    }

    fun inject(previewMediaFragment: PreviewMediaFragment)
}

В фрагменте делаю внедрение в onAttach() вот так:

override fun onAttach(context: Context) {
        super.onAttach(context)
        Log.i(TAG, "onAttach: ")
        (requireActivity().application as BaseApplication).appComponent.getPreviewComponent()
            .create(this).inject(this)
    }

Код работает, но я не знаю норм это или нет?
Просто если руками создать адаптер - код выглядит гораздо проще.

Почему не создаётся компонент Dagger, при написании интерфейса на Kotlin?

Денис, а если внутри Parent фрагмента нужно показывать DialogFragment - его тоже лучше не внедрять, а создавать через фабричный метод?

Мой фрагмент выглядит вот так. В нем есть зависимость на другой класс.

class SearchSettingsFragment @Inject constructor() : DialogFragment() {
    private var activityContract: Activity? = null

    @Inject
    lateinit var searchParams: SearchParams

...
}

Как добавить логику парсинга Json, не используя десериализатор?

Денис, скажи пожалуйста правильно ли я делаю?
Json достаточно большой. Много вложенных объектов. Испольльзую для создания data классов генераторы Pojo из Json. У меня получается 7 связанных классов. Корневой класс называется Collection, по имени корневого Json объекта.
Данный классы я оставляю как есть.
Далее мне нужно создать класс-конвертер, который преобразует эти семь новых классов в один (тот самый класс который возращал десериализатор и на основе которого работает мое приложение).
Хорошо ли это иметь 7 классов которые генерятся на основе Json?

Почему не создаётся компонент Dagger, при написании интерфейса на Kotlin?

Денис, спасибо большое. Фрагмент взял просто ради примера.

Почему в Activity нужно внедрять зависимости используя Component?

Обратился к полю engine в MainActivity. NPE не бросился. Данное поле же помечено @Inject и зависимость подтягивается.

Почему в Activity нужно внедрять зависимости используя Component?

По каким источникам Вы изучали данную библиотеку?

Как сделать из двух Rx запросов один, используя flatMap?

Денис, спасибо большое за ответ, но мне непонятно куда и что я должен копировать (вторая часть твоего ответа). У меня есть MutableLiveData, в которую я ложу ответ, но для View - использую LiveData.

private val _downloadedMediaDetailsResponse =  MutableLiveData<MediaDetail>()
val downloadedMediaResponse: LiveData<MediaDetail>
get() = _downloadedMediaDetailsResponse

Что почитать по архитектурным шаблонам проектирования?

Adamos, Я хочу использовать оба подхода, но сначала понять общие принципы, а уже потом лезть в частные случаи и статьи на хабрах.

Как вызвать retry() для асинхронного метода, изменив параметры вызова этого метода?

Спасибо! Три дня уже колдую над этим методом...

Почему fragmentmanager разрушается после изменения конфигурации?

Сергей Шиловский, А разве может быть такое, что Activity создастся позже чем фрагмент? У меня же в onAttach() методе фрагмента происходит инициализация ссылки на Activity. По идее Activity должна быть создана и способной вызывать свои методы.

Почему fragmentmanager разрушается после изменения конфигурации?

Сергей Шиловский,
Что такое transaction и что вообще выполняет этот метод?
Погуглил - не нашел ничего связанного с управлением жизненным циклом. В основном все ссылки ведут на deprecated class Transaction по работе с БД.

Как реализовать мониторинг состояний сетевых запросов в MVVM?

Большое спасибо!

Как правильно очистить ресурсы во вложенном запросе RxJava?

Ахах)))ну да согласен. Писал метод чисто эмпирическим путем, абы работало. Спасибо, буду разбираться.

Как поймать нажатие клавиши Back в EditText?

Как в onKeyListener отловить кнопку back? Я пробовал этот вариант, но у меня не получилось. В статье, на которую я указал ссылку сказано, что такой способ не сработает.