kotlinx.coroutines

kotlinx.coroutines copied to clipboard

Replace usages of DCLL with CLL in JobSupport and friends

2

This is a subtask required for #3886 Work outline: * [x] Get rid of DCSS (double compare single swap) primitive in `JobSupport` state transitions * [ ] Prototype the solution...

qwwdfsad

Add a .throttle(Duration) Flow extension that prevents short burst of emission in a time frame

2

**Use case** I read BLE characteristics and send them throught a Flow for the rest of my application to act on it. The BLE characteristics are based on real world...

NinoDLC

Remove concurrent doubly linked list from kotlinx.coroutines codebase

1

We have `LockFreeLinkedListNode` and co. based on the ["Lock-Free and Practical Doubly Linked List-Based Deques Using Single-Word Compare-and-Swap"](https://citeseerx.ist.psu.edu/viewdoc/download?doi=10.1.1.140.4693&rep=rep1&type=pdf) paper. The implementation has a long-standing tail of issues: 1. The paper...

qwwdfsad

Add start parameter to launchIn extension for Flow

10

Usage would look like so: ```kotlin someFlow.launchIn(lifecycleScope, start = CoroutineStart.UNDISPATCHED) ``` My current use-case is to have the UI be set up synchronously by the flow collection start, avoiding an...

LouisCAD

Unstarted lazy job prevents parent from completion

2

The following example hangs forever: ```kotlin class LazyChildTest : CoroutineScope { @get:Rule val timeout: CoroutinesTimeout = CoroutinesTimeout.seconds(1) private val parent = Job() override val coroutineContext: CoroutineContext = parent @BeforeTest fun...

cy6erGn0m

Provide an API to check whether debug mode is enabled

1

We already have a notion of debug mode in our documentation, but we do not have an API to check whether the mode is enabled. It can be useful in...

qwwdfsad

Feature Request: invokeOnCompletion handler for suspendCancellableCoroutine

14

It is inconvenient to use `suspendCancellableCoroutine` to wrap an API that requires a callback to be unregistered after receiving the call. Examples include "event bus" or "broadcast" APIs which do...

jschools

Timeout not detected on newSingleThreadContext() when withTimeout wraps a blocking job

14

If `withTimeout` wraps a blocking job, it does not detect a timeout in conjunction with `newSingleThreadContext()`. Timeout detection works as expected with other dispatcher flavors: ```kotlin import kotlinx.coroutines.* // ktlint-disable...

OliverO2

Feature: Flow.conflate with custom callback for merging elements

3

**Use case** I have some data, which is represented as flow of updates. And I need to calculate SateFlow of some derived data, which is essentially can be thought as...

kunyavskiy

Unstable context preservation invariant in Flow

4

Consider https://pl.kotl.in/g6pikDNtt: ``` val topFlow = flow { emit(1) delay(100L) emit(2) emit(3) delay(300L) emit(4) } val bottomFlow = flow { topFlow .onEach { emit(it) } .sample(periodMillis = 200) .collect {...

lowasser