<RxJava Scheduler.Worker equivalent in Kotlin coro...
# stackoverflow
u
RxJava Scheduler.Worker equivalent in Kotlin coroutines I try to migrate below code which RxJava to Kotlin coroutines. This uses uses RxJava Scheduler.Worker to do json parsin in own thread. Is there something similar in Kotlin Coroutines? // RxJava class MessagesRepository() { private val messagesSubject = PublishSubject.create() val messages = messagesSubject.toFlowable(BackpressureStrategy.BUFFER) val scheduler = Schedulers.computation() private fun setClientCallbacks() { val worker =...