Merge "[kairos] uncap transaction scheduler channel" into main

    private val muxMovers = ArrayDeque<MuxDeferredNode<*, *, *>>()

    private val deactivations = ArrayDeque<PushNode<*>>()

    private val outputDeactivations = ArrayDeque<Output<*>>()

    private val inputScheduleChan = Channel<ScheduledAction<*>>()

    private val inputScheduleChan = Channel<ScheduledAction<*>>(Channel.UNLIMITED)

    override fun scheduleOutput(output: Output<*>) {

        fastOutputs.add(output)

                onResult.cancel()

                return@also

            }

            val job =

                coroutineScope.launch {

                    inputScheduleChan.send(

            inputScheduleChan.trySend(

                ScheduledAction(reason, onStartTransaction = block, onResult = onResult)

            )

        }

            onResult.invokeOnCompletion { job.cancel() }

        }

    inline fun <R> runThenDrainDeferrals(block: () -> R): R =

        block().also { deferScopeImpl.drainDeferrals() }