Arkadii Ivanov
02/03/2020, 11:05 AMsimon.vergauwen
02/03/2020, 11:08 AMConcurrent
implementation for all its types. Bracket
which composes 3 of the same Rx types together while guaranteeing resource-safety was especially hard.
I was surprised neither frameworks exposes such an operation, they only support side-effecting onces.Arkadii Ivanov
02/03/2020, 11:11 AMsimon.vergauwen
02/03/2020, 11:11 AMArkadii Ivanov
02/03/2020, 11:12 AMsimon.vergauwen
02/03/2020, 11:17 AMArkadii Ivanov
02/03/2020, 11:17 AMsimon.vergauwen
02/03/2020, 11:19 AMQueue
etc in Arrow Fx as well which is the FP equivalent of Channel
Arkadii Ivanov
02/03/2020, 11:19 AMWe have Queue etc in Arrow Fx as well which is the FP equivalent of Channel
simon.vergauwen
02/03/2020, 11:20 AMSchedulers.computation()
was acting weird but <http://Schedulers.io|Schedulers.io>()
wasn’tArkadii Ivanov
02/03/2020, 11:20 AMsimon.vergauwen
02/03/2020, 11:20 AMQueue
in Arrow Fx. It semantically blocks, or suspends.Arkadii Ivanov
02/03/2020, 11:20 AMcontinueOn
?simon.vergauwen
02/03/2020, 11:21 AMcontinueOn
is simply subscribeOn
observeOn
Arkadii Ivanov
02/03/2020, 11:22 AMcontinueOn
accepts CoroutineContext
simon.vergauwen
02/03/2020, 11:22 AMobserveOn
and you can install multiple timesArkadii Ivanov
02/03/2020, 11:23 AMSingle
wrapped into SingleK
. The last one has continueOn
operator. I need to implement this operator.simon.vergauwen
02/03/2020, 11:26 AMScheduler
from a CoroutineContext
shouldn’t be any different from creating a scheduler from an ExecutorService
, isn’t it?Arkadii Ivanov
02/03/2020, 11:34 AMExecutorScheduler
implementation is ~450 lines long. And it uses tricky queue under the hood.