MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-02-04 23:39:07 +07:00
Code Issues Packages Projects Releases Wiki Activity

[collab] mark obsolete APIs

Browse Source 
GitOrigin-RevId: 73f6b19bb971e558e3bfbefca253c19d6c26d432
This commit is contained in:
Ivan Semenov
2024-06-06 19:00:29 +02:00
committed by intellij-monorepo-bot
parent b707a5efc6
commit 640a8f0200
1 changed files with 26 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
platform/collaboration-tools/src/com/intellij/collaboration/async/CoroutineUtil.kt
View File

@@ -285,20 +285,10 @@ fun <T> Flow<T>.modelFlow(cs: CoroutineScope, log: Logger): SharedFlow<T> =
catch { log.error(it) }.shareIn(cs, SharingStarted.Lazily, 1)
/**
* Associate each *item* [T] *key* [K] in the iterable from the receiver flow (source list) with a *value* [V]
*
* Keys are distinguished by a [hashingStrategy]
*
* When a new iterable is received:
* * a new [CoroutineScope] and a new value is created via [valueExtractor] for new items
* * existing values are updated via [update] if it was supplied
* * values for missing items are removed and destroyed via [destroy]
*
* Order of the values in the resulting map is the same as in the source iterable
* All [CoroutineScope]'s of values are only active while the resulting flow is being collected
*
* **Returned flow never completes**
* The destructor is never necessary because cleanup can be performed on scope cancellation
* @see associateCachingBy
*/
@ApiStatus.Obsolete
fun <T, K, V> Flow<Iterable<T>>.associateCachingBy(keyExtractor: (T) -> K,
hashingStrategy: HashingStrategy<K>,
valueExtractor: CoroutineScope.(T) -> V,
@@ -315,6 +305,27 @@ fun <T, K, V> Flow<Iterable<T>>.associateCachingBy(keyExtractor: (T) -> K,
}
}
/**
* Associate each *item* [T] *key* [K] in the iterable from the receiver flow (source list) with a *value* [V]
*
* Keys are distinguished by a [hashingStrategy]
*
* When a new iterable is received:
* * a new [CoroutineScope] and a new value is created via [valueExtractor] for new items
* * existing values are updated via [update] if it was supplied
* * values for missing items are removed and their scope is cancelled
*
* Order of the values in the resulting map is the same as in the source iterable
* All [CoroutineScope]'s of values are only active while the resulting flow is being collected
*
* **Returned flow never completes**
*/
fun <T, K, V> Flow<Iterable<T>>.associateCachingBy(keyExtractor: (T) -> K,
hashingStrategy: HashingStrategy<K>,
valueExtractor: CoroutineScope.(T) -> V,
update: (suspend V.(T) -> Unit)? = null)
: Flow<Map<K, V>> = associateCachingBy(keyExtractor, hashingStrategy, valueExtractor, { }, update)
/**
* @see associateCachingBy
*
@@ -326,6 +337,8 @@ private fun <T, R> Flow<Iterable<T>>.associateCaching(hashingStrategy: HashingSt
return associateCachingBy({ it }, hashingStrategy, { mapper(it) }, { }, update)
}
@ApiStatus.Internal
@ApiStatus.Obsolete
fun <ID : Any, T, R> Flow<Iterable<T>>.mapCaching(sourceIdentifier: (T) -> ID,
mapper: CoroutineScope.(T) -> R,
destroy: suspend R.() -> Unit,