1
ответ

Как реализовать выполнение процесса как реактивное `Observable [String]

Я хочу представить выполнение внешнего процесса в виде Observable [String], где String - строка из вывода процесса. Вот пример того, что я делаю, это работает: import monix.eval.Task import monix.execution ....
вопрос задан: 22 January 2019 18:27
1
ответ

monix: Task.executeWithFork предотвращает выполнение?

Я не могу понять, почему добавление executeWithFork препятствует выполнению задачи в следующем примере: import java.util.concurrent.TimeUnit import monix.execution.schedulers.SchedulerService import ...
вопрос задан: 18 January 2019 08:43
0
ответов

Какой подход к планированию следует использовать для задач ввода-вывода, которые могут блокировать неограниченное время до определенной точки?

Я сомневаюсь, какую стратегию планирования использовать для блокировки задач ввода-вывода в приведенном ниже коде. Используя метод scheduleWithFixedDelayDispatchTask, кажется, что я буду создавать задачи один после ...
вопрос задан: 21 January 2019 12:36