У меня есть поток ResponseMessage , который может быть разных подтипов. Я хотел бы разделить поток на потоки, где я могу обрабатывать каждый тип в своем собственном потоке. Моя первая попытка привела к этому, чего я не вижу. file.readLines()...

У меня есть объект, который генерирует разные строки в случайные моменты времени, и мне нужно подключиться к этому генератору, чтобы взять эти строки и предоставить их пользовательскому интерфейсу (возможно, это будет несколько подписчиков в разных...

Что я хотел сделать, так это иметь Flowable с буфером противодавления одного элемента, который будет хранить последний созданный из потока. Я пробовал использовать Flowable.onBackpressureBuffer (1, () -> {},...

В приложении для Android процесс выглядит следующим образом: сначала я извлекаю заметки из локального SQLite, а затем делаю вызовы Http для каждой заметки. Я использую составные одноразовые элементы, чтобы хранить все одноразовые элементы и...