Adds an event subscription. Every time an event occurs, the handler is called, receiving an instance of the event. The subscription is removed when the given lifetime expires.

advise

fun IVoidSource.advise(lifetime: Lifetime, handler: () -> Unit)

adviseAddRemove

open fun adviseAddRemove(lifetime: Lifetime, handler: (AddRemove, Int, T) -> Unit)

Adds a subscription to additions and removals of list elements. When a list element is updated, the handler is called twice: to report the removal of the old element and the addition of the new one.

adviseEternal

fun <T> ISource<T>.adviseEternal(handler: (T) -> Unit)

Adds an event subscription that never gets removed.

adviseNotNull

fun <T : Any> ISource<T?>.adviseNotNull(lifetime: Lifetime, handler: (T) -> Unit)

Adds an event subscription that filters out null values.

adviseNotNullOnce

fun <T : Any> ISource<T?>.adviseNotNullOnce(lifetime: Lifetime, handler: (T) -> Unit): LifetimeDefinition

Executes handler exactly once when the source fires an event with a non-null value, then terminates the subscription

adviseOnce

fun <T> ISource<T>.adviseOnce(lifetime: Lifetime, handler: (T) -> Unit)

Executes handler exactly once then terminates the subscription

adviseSuspend

fun <T> ISource<T>.adviseSuspend(lifetime: Lifetime, scheduler: IScheduler, handler: suspend (T) -> Unit)

fun <T> ISource<T>.adviseSuspend(lifetime: Lifetime, context: CoroutineContext, handler: suspend (T) -> Unit)

adviseUntil

fun <T> ISource<T>.adviseUntil(lifetime: Lifetime, handler: (T) -> Boolean)

Holds subscription until handler returns true or lifetime is terminated

adviseWithPrev

fun <T> ISource<T>.adviseWithPrev(lifetime: Lifetime, handler: (prev: Maybe<T>, cur: T) -> Unit)

asProperty

fun <T> ISource<T>.asProperty(defaultValue: T): IPropertyView<T>

clear

open override fun clear()

contains

open operator override fun contains(element: T): Boolean

containsAll

open override fun containsAll(elements: Collection<T>): Boolean

distinct

fun <T> ISource<T>.distinct(): ISource<T>

filter

fun <T> ISource<T>.filter(f: (T) -> Boolean): ISource<T>

flowInto

fun <TSrc> ISource<TSrc>.flowInto(lifetime: Lifetime, target: IMutablePropertyBase<TSrc>)

fun <TSrc : Any, TDst : Any> ISource<IViewableList.Event<TSrc>>.flowInto(lifetime: Lifetime, target: IMutableViewableList<TDst>, tf: (TSrc) -> TDst)

fun <TKey : Any, TValue : Any> ISource<IViewableMap.Event<TKey, TValue>>.flowInto(lifetime: Lifetime, target: IMutableViewableMap<TKey, TValue>, tf: (TValue) -> TValue)

fun <TSrc : Any, TDst : Any> ISource<IViewableSet.Event<TSrc>>.flowInto(lifetime: Lifetime, target: IMutableViewableSet<TDst>, tf: (TSrc) -> TDst)

fun <T> ISource<T>.flowInto(lifetime: Lifetime, target: ISignal<T>)

Whenever a change happens in this source, fires a change in the target signal of the same type.

fun <TSrc, TDst> ISource<TSrc>.flowInto(lifetime: Lifetime, target: IMutablePropertyBase<TDst>, tf: (TSrc) -> TDst)

Whenever a change happens in this source, changes the target property of the same type.

fun <TSource, TTarget> ISource<TSource>.flowInto(lifetime: Lifetime, target: ISignal<TTarget>, tf: (TSource) -> TTarget)

Whenever a change happens in this source, fires a change in the target signal obtained by running the given tf function.

fold

fun <TSource, TResult : Any> Iterable<IPropertyView<TSource>>.fold(lifetime: Lifetime, initial: TResult, func: (TResult, TSource) -> TResult): OptProperty<TResult>

foldOpt

fun <TSource : Any, TResult : Any> Iterable<IOptPropertyView<TSource>>.foldOpt(lifetime: Lifetime, initial: TResult, func: (TResult, TSource) -> TResult): OptProperty<TResult>

foldRight

fun <TSource, TResult : Any> List<IPropertyView<TSource>>.foldRight(lifetime: Lifetime, initial: TResult, func: (TSource, TResult) -> TResult): OptProperty<TResult>

foldRightOpt

fun <TSource : Any, TResult : Any> List<IOptPropertyView<TSource>>.foldRightOpt(lifetime: Lifetime, initial: TResult, func: (TSource, TResult) -> TResult): OptProperty<TResult>

get

open operator override fun get(index: Int): T

indexOf

open override fun indexOf(element: T): Int

isEmpty

open override fun isEmpty(): Boolean

iterator

open operator override fun iterator(): MutableIterator<T>

lastIndexOf

open override fun lastIndexOf(element: T): Int

listIterator

open override fun listIterator(): MutableListIterator<T>

open override fun listIterator(index: Int): MutableListIterator<T>

map

fun <T, R> ISource<T>.map(f: (T) -> R): ISource<R>

Returns a new source which remaps events happening in this source using the given function f.

nextFalseValue

suspend fun ISource<Boolean>.nextFalseValue(): Boolean

nextFalseValueAsync

fun ISource<Boolean>.nextFalseValueAsync(lifetime: Lifetime): Deferred<Boolean>

nextNotNullValue

suspend fun <T : Any> ISource<T?>.nextNotNullValue(): T

nextNotNullValueAsync

fun <T : Any> ISource<T?>.nextNotNullValueAsync(lifetime: Lifetime): Deferred<T>

nextTrueValue

suspend fun ISource<Boolean>.nextTrueValue(): Boolean

nextTrueValueAsync

fun ISource<Boolean>.nextTrueValueAsync(lifetime: Lifetime): Deferred<Boolean>

nextValue

suspend fun <T> ISource<T>.nextValue(condition: (T) -> Boolean = { true }): T

nextValueAsync

fun <T> ISource<T>.nextValueAsync(lifetime: Lifetime, condition: (T) -> Boolean = { true }): Deferred<T>

remove

open override fun remove(element: T): Boolean

removeAll

open override fun removeAll(elements: Collection<T>): Boolean

removeAt

open override fun removeAt(index: Int): T

removeRange

fun removeRange(fromIndex: Int, toIndex: Int)

restOrNull

fun <T> List<T>?.restOrNull(): List<T>?

retainAll

open override fun retainAll(elements: Collection<T>): Boolean

set

open operator override fun set(index: Int, element: T): T

subList

open override fun subList(fromIndex: Int, toIndex: Int): MutableList<T>

sync

fun sync(newValues: Collection<T>): Boolean

Synchronizes the viewable list by adding missing elements and removing unmatched elements. If the order of equal values is not changed, then they won't be modified. However, even if equal elements exist in both lists, but order is swapped, then they will be removed and re-added to satisfy the new values order. It helps drastically reduce the number of change events if the collection is unmodified at all or just a few elements are changed compared to the classical approach with 'clear' and 'addAll'.

throttleLast

fun <T : Any> ISource<T>.throttleLast(timeout: Duration, scheduler: IScheduler): ISource<T>

toImmutableStack

fun <T : Any> List<T>.toImmutableStack(): ImmutableStack<T>

view

open override fun view(lifetime: Lifetime, handler: (Lifetime, Pair<Int, T>) -> Unit)

Adds a subscription to changes of the contents of the list.

open fun view(lifetime: Lifetime, handler: (Lifetime, Int, T) -> Unit)

Adds a subscription to changes of the contents of the list, receiving the index and value as separate parameters.

viewableTail

fun <T : Any> IViewableList<T>.viewableTail(): IPropertyView<T?>

Returns a property which evaluates to the last element of the list and is updated as elements are added to the list or removed from it.

viewNotNull

fun <T : Any> IViewable<T?>.viewNotNull(lifetime: Lifetime, handler: (Lifetime, T) -> Unit)

Adds a subscription to changes to this viewable's contents and filters out null values. The subscription is removed when the given lifetime expires.

whenFalse

fun IViewable<Boolean>.whenFalse(lifetime: Lifetime, action: (Lifetime) -> Unit)

Executes the given action every time the value of the property changes to false.

whenTrue

fun IViewable<Boolean>.whenTrue(lifetime: Lifetime, action: (Lifetime) -> Unit)

Executes the given action every time the value of the property changes to true.