cacheonhand-attendants/io.github.notoriouscorgi.cacheonhand.operations/CacheableFlowWithInput

CacheableFlowWithInput

class CacheableFlowWithInput<TInput : CacheableInput.FlowInput, TData, TError : Throwable>(coroutineScope: CoroutineScope, launchFlow: (input: TInput) -> Flow<TData?>, startingCacheKey: TInput? = null, cache: OnHandCache, dispatcher: CoroutineDispatcher = Dispatchers.Default, ttl: Duration? = null, initialFetchState: FetchState = FetchState.IDLE, tryMarkActive: suspend (TInput) -> Boolean = { true }, markInactive: suspend (TInput) -> Unit = {})

Constructors

constructor(coroutineScope: CoroutineScope, launchFlow: (input: TInput) -> Flow<TData?>, startingCacheKey: TInput? = null, cache: OnHandCache, dispatcher: CoroutineDispatcher = Dispatchers.Default, ttl: Duration? = null, initialFetchState: FetchState = FetchState.IDLE, tryMarkActive: suspend (TInput) -> Boolean = { true }, markInactive: suspend (TInput) -> Unit = {})

Properties

result

val result: StateFlow<CacheableFlowResult<TData, TError>>

Functions

component1

operator fun component1(): StateFlow<CacheableFlowResult<TData, TError>>

launch

suspend fun launch(queryInput: TInput, onEachSuccess: suspend (TData) -> Unit? = null, onError: suspend (TError) -> Unit? = null)