Skip to content

Introduce SharedFlow.collectLatest - #4454

Merged
dkhalanskyjb merged 1 commit into
developfrom
dkhalanskyjb/sharedFlow.collectLatest
Sep 15, 2025
Merged

dkhalanskyjb merged 1 commit into
developfrom
dkhalanskyjb/sharedFlow.collectLatest

Conversation

@dkhalanskyjb

Copy link
Copy Markdown
Collaborator

@dkhalanskyjb
dkhalanskyjb requested a review from qwwdfsad June 23, 2025 12:46
@qwwdfsad

Copy link
Copy Markdown
Member

Is it not merged on purpose?

@dkhalanskyjb
dkhalanskyjb merged commit bec405b into develop Sep 15, 2025
@dkhalanskyjb
dkhalanskyjb deleted the dkhalanskyjb/sharedFlow.collectLatest branch September 15, 2025 11:56
@dkhalanskyjb

Copy link
Copy Markdown
Collaborator Author

Not really. Basically, it was waiting for my own review.

markharding pushed a commit to futo-org/Harbor that referenced this pull request Oct 13, 2026
This PR contains the following updates:

| Package | Change | [Age](https://docs.renovatebot.com/merge-confidence/) | [Confidence](https://docs.renovatebot.com/merge-confidence/) |
|---|---|---|---|
| [org.jetbrains.kotlinx:kotlinx-coroutines-test](https://github.com/Kotlin/kotlinx.coroutines) | `1.10.1` → `1.11.0` | ![age](https://developer.mend.io/api/mc/badges/age/maven/org.jetbrains.kotlinx:kotlinx-coroutines-test/1.11.0?slim=true) | ![confidence](https://developer.mend.io/api/mc/badges/confidence/maven/org.jetbrains.kotlinx:kotlinx-coroutines-test/1.10.1/1.11.0?slim=true) |
| [org.jetbrains.kotlinx:kotlinx-coroutines-android](https://github.com/Kotlin/kotlinx.coroutines) | `1.10.1` → `1.11.0` | ![age](https://developer.mend.io/api/mc/badges/age/maven/org.jetbrains.kotlinx:kotlinx-coroutines-android/1.11.0?slim=true) | ![confidence](https://developer.mend.io/api/mc/badges/confidence/maven/org.jetbrains.kotlinx:kotlinx-coroutines-android/1.10.1/1.11.0?slim=true) |
| [org.jetbrains.kotlinx:kotlinx-coroutines-core](https://github.com/Kotlin/kotlinx.coroutines) | `1.10.1` → `1.11.0` | ![age](https://developer.mend.io/api/mc/badges/age/maven/org.jetbrains.kotlinx:kotlinx-coroutines-core/1.11.0?slim=true) | ![confidence](https://developer.mend.io/api/mc/badges/confidence/maven/org.jetbrains.kotlinx:kotlinx-coroutines-core/1.10.1/1.11.0?slim=true) |

---

### Release Notes

<details>
<summary>Kotlin/kotlinx.coroutines (org.jetbrains.kotlinx:kotlinx-coroutines-test)</summary>

### [`v1.11.0`](https://github.com/Kotlin/kotlinx.coroutines/blob/HEAD/CHANGES.md#Version-1110)

[Compare Source](Kotlin/kotlinx.coroutines@1.10.2...1.11.0)

##### Various

- Kotlin was updated to 2.2.20 ([#&#8203;4545](Kotlin/kotlinx.coroutines#4545)).
- Improved the published jar files ([#&#8203;3842](Kotlin/kotlinx.coroutines#3842), [#&#8203;4599](Kotlin/kotlinx.coroutines#4599)).
- Various documentation improvements, including complete rewrites of structured concurrency and error handling-related KDoc ([#&#8203;4433](Kotlin/kotlinx.coroutines#4433), [#&#8203;4596](Kotlin/kotlinx.coroutines#4596)).

##### Breaking changes and deprecations

- Moved `Promise`-related functions from JS and Wasm/JS to the new `web` target. On Wasm/JS, this is a breaking change. Before the change, `Promise` on Wasm/JS could work with arbitrary Kotlin types, but now, only `JsAny` subtypes are accepted ([#&#8203;4563](Kotlin/kotlinx.coroutines#4563)).
- Changed handling of coroutine exceptions that can't be propagated on JS and Wasm/JS. Before, exceptions were logged, but now, they are reported to the JS runtime ([#&#8203;4451](Kotlin/kotlinx.coroutines#4451), [#&#8203;4631](Kotlin/kotlinx.coroutines#4631)).
- Deprecated using `CoroutineDispatcher` as the coroutine context key; now, `ContinuationInterceptor` has to be used instead ([#&#8203;4333](Kotlin/kotlinx.coroutines#4333)).
- Advanced the deprecation levels on `kotlinx-coroutines-test` APIs ([#&#8203;4604](Kotlin/kotlinx.coroutines#4604)).
- Added lint functions that mark passing a `Job` to coroutine builders as deprecated ([#&#8203;4435](Kotlin/kotlinx.coroutines#4435)).

##### Bug fixes and improvements

- Added a `callsInPlace(EXACTLY_ONCE)` contract to `runBlocking` in code shared between JVM and Native ([#&#8203;4368](Kotlin/kotlinx.coroutines#4368)).
- Added a `callsInPlace(EXACTLY_ONCE)` contract to `suspendCancellableCoroutine` ([#&#8203;4574](Kotlin/kotlinx.coroutines#4574)).
- Fixed `flowOn` incorrectly handling `ThreadContextElement` updates ([#&#8203;4403](Kotlin/kotlinx.coroutines#4403)).
- Fixed exceptions in user-supplied `Thread.UncaughtExceptionHandler` instances causing the internal coroutines machinery to fail ([#&#8203;4516](Kotlin/kotlinx.coroutines#4516)).
- Fixed `CoroutineDispatcher.asScheduler` in the RxJava integration not cancelling outstanding work when a `Worker` gets cancelled, which led to memory leaks in some scenarios ([#&#8203;4615](Kotlin/kotlinx.coroutines#4615)).
- Fixed `SharedFlow` entering an invalid state when a subscriber and an emitter are cancelled simultaneously ([#&#8203;4583](Kotlin/kotlinx.coroutines#4583)).
- Fixed an R8 optimization leading to `shareIn`/`stateIn` coroutines getting garbage-collected ([#&#8203;4646](Kotlin/kotlinx.coroutines#4646)). Thanks, [@&#8203;solevic](https://github.com/solevic)!

##### Small additions

- Added `CompletableDeferred.asDeferred` for obtaining a read-only `Deferred` view ([#&#8203;4408](Kotlin/kotlinx.coroutines#4408)).
- Added `SharedFlow.asFlow` for obtaining a `Flow` view with hidden hot flow semantics ([#&#8203;4530](Kotlin/kotlinx.coroutines#4530)). Thanks, [@&#8203;g000sha256](https://github.com/g000sha256)!
- Added a `StateFlow.collectLatest` overload returning `Nothing` to assist with finding unreachable code ([#&#8203;4454](Kotlin/kotlinx.coroutines#4454)).
- Added `ReceiveChannel.consumeTo` for consuming a `ReceiveChannel` into a `MutableCollection` ([#&#8203;4520](Kotlin/kotlinx.coroutines#4520)).
- Added a `StateFlow<T>.onSubscription` overload returning a `StateFlow<T>`, similar to `SharedFlow<T>.onSubscription` returning `SharedFlow<T>` ([#&#8203;4275](Kotlin/kotlinx.coroutines#4275)). Thanks, [@&#8203;xit0c](https://github.com/xit0c)!
- Added terminal `Flow` operators for collecting a `Flow` to a `Map` ([#&#8203;1541](Kotlin/kotlinx.coroutines#1541)).

##### Changelog relative to version 1.11.0

No changes, only the version is increased.

### [`v1.10.2`](https://github.com/Kotlin/kotlinx.coroutines/blob/HEAD/CHANGES.md#Version-1102)

[Compare Source](Kotlin/kotlinx.coroutines@1.10.1...1.10.2)

- Fixed the `kotlinx-coroutines-debug` JAR file including the `module-info.class` file twice, resulting in failures in various tooling ([#&#8203;4314](Kotlin/kotlinx.coroutines#4314)). Thanks, [@&#8203;RyuNen344](https://github.com/RyuNen344)!
- Fixed `Flow.stateIn` hanging when the scope is cancelled in advance or the flow is empty ([#&#8203;4322](Kotlin/kotlinx.coroutines#4322)). Thanks, [@&#8203;francescotescari](https://github.com/francescotescari)!
- Improved handling of dispatcher failures in `.limitedParallelism` ([#&#8203;4330](Kotlin/kotlinx.coroutines#4330)) and during flow collection ([#&#8203;4272](Kotlin/kotlinx.coroutines#4272)).
- Fixed `runBlocking` failing to run its coroutine to completion in some cases if its JVM thread got interrupted ([#&#8203;4399](Kotlin/kotlinx.coroutines#4399)).
- Small tweaks, fixes, and documentation improvements.

</details>

---

### Configuration

📅 **Schedule**: (UTC)

- Branch creation
  - "before 9am on tuesday"
- Automerge
  - At any time (no schedule defined)

🚦 **Automerge**: Disabled by config. Please merge this manually once you are satisfied.

♻ **Rebasing**: Whenever PR becomes conflicted, or you tick the rebase/retry checkbox.

🔕 **Ignore**: Close this PR and you won't be reminded about these updates again.

---

 - [ ] <!-- rebase-check -->If you want to rebase/retry this PR, check this box

---

This PR has been generated by [Mend Renovate CLI](https://github.com/renovatebot/renovate).
<!--renovate-debug:eyJjcmVhdGVkSW5WZXIiOiI0NC4xMzMuMCIsInVwZGF0ZWRJblZlciI6IjQ0LjEzMy4wIiwidGFyZ2V0QnJhbmNoIjoiZGV2ZWxvcCIsImxhYmVscyI6WyJkZXBlbmRlbmNpZXMiLCJyZW5vdmF0ZSJdfQ==-->

Reviewed-on: https://code.futo.org/harbor/harbor/pulls/1829
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants