Add way to convert CoroutineDispatcher to Scheduler #1923

Closed

recheej wants to merge 76 commits intoKotlin:developfrom

recheej:rejozil/dispatchertoscheduler

Commits on Dec 28, 2020

created DispatcherScheduler and added first test

Rechee
authored and
recheej
committed
some refactoring to better handle cancellation

Rechee
authored and
recheej
committed
added test for shutdown

Rechee
authored and
recheej
committed
remove redundant isActive check

Rechee
authored and
recheej
committed
remove try finally

Rechee
authored and
recheej
committed
remove comment

Rechee
authored and
recheej
committed
add test for scheduler with SchedulerCoroutineDispatcher

Rechee
authored and
recheej
committed
remove formatting changes

Rechee
authored and
recheej
committed
add missing expectUnreached call in one test

Rechee
authored and
recheej
committed
add a small kdoc

Rechee
authored and
recheej
committed
improve scheduleDirect with delay.

Rechee
authored and
recheej
committed
optimize imports

Rechee
authored and
recheej
committed
formatting changes

Rechee
authored and
recheej
committed
using job from launch for worker

Rechee
authored and
recheej
committed
remove spaces

Rechee
authored and
recheej
committed
simplify job handling, thus fix OOM

Rechee
authored and
recheej
committed
remove back ticks from test names

Rechee
authored and
recheej
committed
call into overload

Rechee
authored and
recheej
committed
now handling non positive delays

Rechee
authored and
recheej
committed
formatting

Rechee
authored and
recheej
committed
using supervisorscope

Rechee
authored and
recheej
committed
using if expressions for return

Rechee
authored and
recheej
committed
create test that verifies sequential ordering

Rechee
authored and
recheej
committed
make rx scheduler worker sequential

Rechee
authored and
recheej
committed
trying out using channel to schedule sequentially

Rechee
authored and
recheej
committed
made queue processing easier. also fixed unit tests

Rechee
authored and
recheej
committed
return DispatcherScheduler dispatcher in asCoroutineDispatcher

Rechee
authored and
recheej
committed
add tests to verify conversions between dispatcher and scheduler

Rechee
authored and
recheej
committed
small comment

Rechee
authored and
recheej
committed
moving stress tests to another class. ignoring for now

Rechee
authored and
recheej
committed
checking in current state of tests

Rechee
authored and
recheej
committed
fix sequential ordering if we're using a dispatcher with thread pool

Rechee
authored and
recheej
committed
simplify isActive check

Rechee
authored and
recheej
committed
let channel suspend while empty

Rechee
authored and
recheej
committed
change test name

Rechee
authored and
recheej
committed
now running blocks directly in scheduleDirect

Rechee
authored and
recheej
committed
test with observables

Rechee
authored and
recheej
committed
running blocks more directly inside DispatcherScheduler. also fixing stress tests

Rechee
authored and
recheej
committed
make asDisposable private

Rechee
authored and
recheej
committed
fix dispose logic

Rechee
authored and
recheej
committed
move queue job processing into constructor

Rechee
authored and
recheej
committed
making schedule block defer to override with delay param

Rechee
authored and
recheej
committed
reduce if nesting

Rechee
authored and
recheej
committed
call RxJavaPlugins before delay

Rechee
authored and
recheej
committed
rx plugins for worker too

Rechee
authored and
recheej
committed
add top level CoroutineExceptionHandler

Rechee
authored and
recheej
committed
adding if check to schedule direct

Rechee
authored and
recheej
committed
now using coroutines test to assert rxjavaplugins call

Rechee
authored and
recheej
committed
remove queue processing job

Rechee
authored and
recheej
committed
improving how jobs are added to the channel

Rechee
authored and
recheej
committed
adding comment about keepMe function

Rechee
authored and
recheej
committed
use run blocking test for tests that call delay

Rechee
authored and
recheej
committed
removing redundant thread tests

Rechee
authored and
recheej
committed
separate plugin tests

Rechee
authored and
recheej
committed
adding more tests for worker tasks

Rechee
authored and
recheej
committed
make worker job private

Rechee
authored and
recheej
committed
check for job cancelled

Rechee
authored and
recheej
committed
remove println

Rechee
authored and
recheej
committed
refactor tests to be more generic for worker tests in next commit

Rechee
authored and
recheej
committed
wrote tests for scheduler worker and made fixes based off tests

Rechee
authored and
recheej
committed
updating scheduler stress tests to include worker tests

Rechee
authored and
recheej
committed
make sure we're waiting for delayJob properly

Rechee
authored and
recheej
committed
refactor delay logic (again :)) to delay first before enqueuing work

Rechee
authored and
recheej
committed
remove redundant expect

Rechee
authored and
recheej
committed
remove redundant channel close

Rechee
authored and
recheej
committed
using one job for both non-delayed and delayed. also fix redundant job with task itself

Rechee
authored and
recheej
committed
remove redundant modifier

Rechee
authored and
recheej
committed
api dump

Rechee
authored and
recheej
committed
use start function and reuse JobDisposable

Rechee
authored and
recheej
committed
remove addTaskToQueue function

Rechee
authored and
recheej
committed
fix typo in tests

Rechee
authored and
recheej
committed
unit test for multiple workers

Rechee
authored and
recheej
committed
maintain binary compat. also formatting

Rechee
authored and
recheej
committed
api dump

Rechee
authored and
recheej
committed
change if statements

Rechee
authored and
recheej
committed
add asScheduler extension for rx3
recheej
committed