У меня есть мои наблюдаемые, определенные следующим образом val initLoading = Observable.fromCallable { println("${System.currentTimeMillis()}") } .subscribeOn(Schedulers.computation()) .delay(WAIT_TIME,...

У меня есть список List<FileModel> FileModel - это просто класс, содержащий id: Int id - это идентификатор файла фотографии, который мне нужно получить и передать в Bitmap. У меня есть запрос: fun getFile(fileId: Int):...

Я видел здесь другие вопросы, связанные с этой ошибкой, но все еще не могу исправить. Кроме того, я задаю этот вопрос, потому что, в отличие от других вопросов здесь, я получаю эту ошибку только при преобразовании кода в Kotlin из Java. Я...

Кажется, существует ограничение на количество Observables, которые можно использовать в качестве параметров в методе zip для Kotlin. Если это так, то какова лучшая альтернатива? Например, когда я использую 9 параметров, все работает, как и...

Я попробовал это с помощью следующей программы, но она показывает ошибку, что ожидается переменная kotlin: [

Я использую RxJava/Kotlin Observable#take() для получения первых 50 элементов из списка. Но оператор #take() ведет себя не так, как должен, согласно документам Rx. В документах Rx #take() определяется как: «Испускать только первые n...

Я хотел попробовать RxJava с kotlin, чтобы упростить кодирование, поэтому я сделал это: fun postAnswers() { disposable = getToken.execute().subscribe({ token -> questions.forEach { form -> val answers =...

У меня есть класс данных Category и класс данных Plan . Каждый Category имеет список идентификаторов планов. Категории и планы хранятся в комнате. Я пытаюсь создать локальный List<Any> , где я добавляю каждую категорию в список, а затем...

У меня есть проблема, и я не знаю, как решить ее с помощью лучшего подхода. Проблема в том, что я запрашиваю веб-API Spotify, и в некоторых методах возвращается изображение исполнителя, а в других получается только основная информация об исполнителе....

Я пытаюсь реализовать шаблон обновления состояния избыточности с помощью RXJava. val subject=PublishSubject.create() val subject1=PublishSubject.create() // multiple threads posting // on subject and subject1 here. Concurrently...