datasourcex-util/com.caplin.integration.datasourcex.util.flow/CompletingSharedFlowCache

CompletingSharedFlowCache

fun interface CompletingSharedFlowCache<K : Any, T>(source)

A cache of flows which each follow the behaviour of shareInCompleting - i.e. they share a single upstream and pass completion and errors on to the downstream.

Types

Companion

object Companion

Functions

get

abstract operator fun get(key: K, supplier: (K) -> Flow<T>): CompletingSharedFlow<T>

If the requested key K is not found in the cache when the CompletingSharedFlow returned by get is subscribed to, then the supplier function will be invoked. Any errors throw in supplier are thrown as error events within the flow.

fun <K : Any, T> CompletingSharedFlowCache<K, T>.loading(supplier: (K) -> Flow<T>): LoadingCompletingSharedFlowCache<K, T>

Converts this CompletingSharedFlowCache to a LoadingCompletingSharedFlowCache.