reactive/com.lightningkite.reactive.core/RawReactive

RawReactive

class RawReactive<T>(start: ReactiveState<T> = ReactiveState.notReady) : BaseReactive<T> (source)

A reactive value that exposes its state and allows direct mutation. Used for low-level reactive state management.

Constructors

RawReactive

constructor(start: ReactiveState<T> = ReactiveState.notReady)

Properties

state

open override var state: ReactiveState<T>

waitForNotNull

val <T : Any> Reactive<T?>.waitForNotNull: Reactive<T>

Functions

addAndRunListener

fun Listenable.addAndRunListener(listener: () -> Unit): () -> Unit

Adds a listener and immediately runs it once.

addListener

abstract fun addListener(listener: () -> Unit): () -> Unit

Adds the listener to be called every time this event fires.

await

suspend fun <T> Reactive<T>.await(): T

awaitNotNull

suspend fun <T : Any> Reactive<T?>.awaitNotNull(): T

awaitOnce

suspend fun <T> Reactive<T>.awaitOnce(): T

beginUse

open override fun beginUse(): () -> Unit

Begins using the resource. Returns a function to stop using the resource.

debounce

fun Listenable.debounce(timeMs: Long): Listenable

fun Listenable.debounce(duration: Duration): Listenable

fun <T> Reactive<T>.debounce(timeMs: Long): Reactive<T>

fun <T> Reactive<T>.debounce(duration: Duration): Reactive<T>

exception

inline suspend fun <T> Reactive<T>.exception(): Exception?

flatten

fun <T> Reactive<MutableReactive<T>>.flatten(): MutableReactive<T>

fun <T> Reactive<Reactive<T>>.flatten(): Reactive<T>

invoke

inline suspend operator fun <T> Reactive<T>.invoke(): T

lens

fun <T, L> Reactive<T>.lens(get: (T) -> L): Reactive<L>

lensListenable

fun <T> Listenable.lensListenable(get: () -> T): Reactive<T>

onNextSuccess

fun <T> Reactive<T>.onNextSuccess(action: (T) -> Unit): () -> Unit

plus

operator fun Listenable.plus(other: Listenable): Listenable

state

suspend fun <T> Reactive<T>.state(): ReactiveState<T>

suspend fun <T, V> Reactive<T>.state(get: (ReactiveState<T>) -> V): V

validated

fun <T> Reactive<T>.validated(validate: (T) -> Issue?): Validated<T>

withWrite

fun <T> Reactive<T>.withWrite(action: suspend Reactive<T>.(T) -> Unit): MutableReactive<T>