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

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

every

suspend fun <T : JsAny?> Observable<T>.every(predicate: (T) -> Boolean): Boolean

everyAsync

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

filter

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

finally

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

find

suspend fun <T : JsAny?> Observable<T>.find(predicate: (T) -> Boolean): T

findAsync

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

first

suspend fun <T : JsAny?> Observable<T>.first(): T

firstAsync

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

flatMap

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

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

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

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

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

forEach

suspend fun <T : JsAny?> Observable<T>.forEach(action: (item: T) -> Unit)

forEachAsync

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

inspect

external fun inspect(): Observable<T>

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

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

last

suspend fun <T : JsAny?> Observable<T>.last(): T

lastAsync

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

map

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

reduce

suspend fun <T : JsAny?, U : JsAny?> Observable<T>.reduce(operation: (previousValue: U, currentValue: T, currentIndex: Int) -> U, initialValue: U): U

reduceAsync

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

some

suspend fun <T : JsAny?> Observable<T>.some(predicate: (T) -> Boolean): Boolean

someAsync

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

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

Subscribes to the sequence with callbacks

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

Subscribes to the sequence with an observer

switchMap

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

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

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

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

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

take

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

takeUntil

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

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

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

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

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

toArray

suspend fun <T : JsAny?> Observable<T>.toArray(): ReadonlyArray<T>

toArrayAsync

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