core-ktx/com.tealium.prism.core.ktx

Package-level declarations

Contains additional method definitions specifically aimed at Kotlin callers - they are intended for easy integration or interoperability with other common Kotlin features, such as coroutines.

Functions

asFlow

fun <T> Subscribable<T>.asFlow(): Flow<T>

Converts this Subscribable into a cold Flow.

asStateFlow

fun <T> SubscribableState<T>.asStateFlow(scope: CoroutineScope): StateFlow<T>

Converts this SubscribableState into a StateFlow.

await

suspend fun <T> Single<TealiumResult<T>>.await(): T

Suspends until the Single emits its result, then returns the unwrapped success value.

awaitResult

suspend fun <T> Single<TealiumResult<T>>.awaitResult(): TealiumResult<T>

Suspends until the Single emits its result, returning the full TealiumResult.

collect

suspend fun <T> Subscribable<T>.collect(collector: FlowCollector<T>)

Collects all emissions from this Subscribable by converting it to a Flow and collecting with the given collector.