kotlin-web/web.observable/Observable

Observable

class Observable<out T : JsAny?>(callback: SubscribeCallback<T>)(source)

Constructors

Observable

constructor(callback: SubscribeCallback<T>)

Types

Companion

object Companion

Functions

catch

inline fun <T : JsAny?> Observable<T>.catch(noinline transform: (JsErrorLike?) -> ReadonlyArray<T>): Observable<T>

inline fun <T : JsAny?> Observable<T>.catch(noinline transform: (JsErrorLike?) -> AsyncIterable<T>): Observable<T>

inline fun <T : JsAny?> Observable<T>.catch(noinline transform: (JsErrorLike?) -> JsIterable<T>): Observable<T>

inline fun <T : JsAny?> Observable<T>.catch(noinline transform: (JsErrorLike?) -> Promise<T>): Observable<T>

inline fun <T : JsAny?> Observable<T>.catch(noinline transform: (JsErrorLike?) -> Observable<T>): Observable<T>

drop

fun drop(n: Int): Observable<T>

every

suspend fun every(predicate: (T) -> Boolean, options: SubscribeOptions? = definedExternally): Boolean

everyAsync

fun everyAsync(predicate: (T) -> Boolean, options: SubscribeOptions? = definedExternally): Promise<JsBoolean>

filter

fun filter(predicate: (T) -> Boolean): Observable<T>

finally

fun finally(callback: VoidFunction): Observable<T>

find

suspend fun find(predicate: (T) -> Boolean, options: SubscribeOptions? = definedExternally): T

findAsync

fun findAsync(predicate: (T) -> Boolean, options: SubscribeOptions? = definedExternally): Promise<T>

first

suspend fun first(options: SubscribeOptions? = definedExternally): T

firstAsync

fun firstAsync(options: SubscribeOptions? = definedExternally): Promise<T>

flatMap

fun <R : JsAny?> flatMap(transform: (T) -> ReadonlyArray<R>): Observable<R>

fun <R : JsAny?> flatMap(transform: (T) -> AsyncIterable<R>): Observable<R>

fun <R : JsAny?> flatMap(transform: (T) -> JsIterable<R>): Observable<R>

fun <R : JsAny?> flatMap(transform: (T) -> Promise<R>): Observable<R>

fun <R : JsAny?> flatMap(transform: (T) -> Observable<R>): Observable<R>

forEach

fun forEach(action: (item: T) -> Unit, options: SubscribeOptions? = definedExternally)

forEachAsync

fun forEachAsync(action: (item: T) -> Unit, options: SubscribeOptions? = definedExternally): Promise<Void>

inspect

fun inspect(): Observable<T>

fun inspect(callback: (value: T) -> Unit): Observable<T>

fun inspect(inspector: ObservableInspector<T>): Observable<T>

last

suspend fun last(options: SubscribeOptions? = definedExternally): T

lastAsync

fun lastAsync(options: SubscribeOptions? = definedExternally): Promise<T>

map

fun <R : JsAny?> map(transform: (T) -> R): Observable<R>

reduce

suspend fun <U : JsAny?> reduce( operation: (previousValue: U, currentValue: T, currentIndex: Int) -> U, initialValue: U, options: SubscribeOptions? = definedExternally): U

reduceAsync

fun <U : JsAny?> reduceAsync( operation: (previousValue: U, currentValue: T, currentIndex: Int) -> U, initialValue: U, options: SubscribeOptions? = definedExternally): Promise<U>

some

suspend fun some(predicate: (T) -> Boolean, options: SubscribeOptions? = definedExternally): Boolean

someAsync

fun someAsync(predicate: (T) -> Boolean, options: SubscribeOptions? = definedExternally): Promise<JsBoolean>

fun subscribe(callback: (value: T) -> Unit, options: SubscribeOptions? = definedExternally)

Subscribes to the sequence with callbacks

fun subscribe(observer: SubscriptionObserver<T>, options: SubscribeOptions? = definedExternally)

Subscribes to the sequence with an observer

switchMap

fun <R : JsAny?> switchMap(transform: (T) -> ReadonlyArray<R>): Observable<R>

fun <R : JsAny?> switchMap(transform: (T) -> AsyncIterable<R>): Observable<R>

fun <R : JsAny?> switchMap(transform: (T) -> JsIterable<R>): Observable<R>

fun <R : JsAny?> switchMap(transform: (T) -> Promise<R>): Observable<R>

fun <R : JsAny?> switchMap(transform: (T) -> Observable<R>): Observable<R>

take

fun take(n: Int): Observable<T>

takeUntil

fun takeUntil(notifier: ReadonlyArray<*>): Observable<T>

fun takeUntil(notifier: AsyncIterable<*>): Observable<T>

fun takeUntil(notifier: JsIterable<*>): Observable<T>

fun takeUntil(notifier: Promise<*>): Observable<T>

fun takeUntil(notifier: Observable<*>): Observable<T>

toArray

suspend fun toArray(options: SubscribeOptions? = definedExternally): ReadonlyArray<T>

toArrayAsync

fun toArrayAsync(options: SubscribeOptions? = definedExternally): Promise<ReadonlyArray<T>>