kotlin-web/web.observable/Observable

Observable

class Observable<out T : ERROR CLASS: Symbol not found for JsAny??>(callback: SubscribeCallback<T>)(source)

Constructors

Observable

constructor(callback: SubscribeCallback<T>)

Types

Companion

object Companion

Functions

catch

inline fun <T : ERROR CLASS: Symbol not found for JsAny??> Observable<T>.catch(noinline transform: (JsErrorLike?) -> AsyncIterable<T>): Observable<T>

inline fun <T : ERROR CLASS: Symbol not found for JsAny??> Observable<T>.catch(noinline transform: (JsErrorLike?) -> JsIterable<T>): Observable<T>

inline fun <T : ERROR CLASS: Symbol not found for JsAny??> Observable<T>.catch(noinline transform: (JsErrorLike?) -> Promise<T>): Observable<T>

inline fun <T : ERROR CLASS: Symbol not found for JsAny??> Observable<T>.catch(noinline transform: (JsErrorLike?) -> ReadonlyArray<T>): Observable<T>

inline fun <T : ERROR CLASS: Symbol not found for JsAny??> Observable<T>.catch(noinline transform: (JsErrorLike?) -> Observable<T>): Observable<T>

drop

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

every

suspend fun <T : ERROR CLASS: Symbol not found for JsAny??> Observable<T>.every(predicate: (T) -> Boolean): Boolean

everyAsync

fun everyAsync(predicate: (T) -> Boolean, options: SubscribeOptions? = definedExternally): Promise<ERROR CLASS: Symbol not found for JsBoolean>

filter

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

finally

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

find

suspend fun <T : ERROR CLASS: Symbol not found for JsAny??> Observable<T>.find(predicate: (T) -> Boolean): T

findAsync

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

first

suspend fun <T : ERROR CLASS: Symbol not found for JsAny??> Observable<T>.first(): T

firstAsync

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

flatMap

fun <R : ERROR CLASS: Symbol not found for JsAny??> flatMap(transform: (T) -> AsyncIterable<R>): Observable<R>

fun <R : ERROR CLASS: Symbol not found for JsAny??> flatMap(transform: (T) -> JsIterable<R>): Observable<R>

fun <R : ERROR CLASS: Symbol not found for JsAny??> flatMap(transform: (T) -> Promise<R>): Observable<R>

fun <R : ERROR CLASS: Symbol not found for JsAny??> flatMap(transform: (T) -> ReadonlyArray<R>): Observable<R>

fun <R : ERROR CLASS: Symbol not found for JsAny??> flatMap(transform: (T) -> Observable<R>): Observable<R>

forEach

suspend fun <T : ERROR CLASS: Symbol not found for JsAny??> Observable<T>.forEach(action: (item: T) -> Unit)

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 <T : ERROR CLASS: Symbol not found for JsAny??> Observable<T>.last(): T

lastAsync

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

map

fun <R : ERROR CLASS: Symbol not found for JsAny??> map(transform: (T) -> R): Observable<R>

reduce

suspend fun <T : ERROR CLASS: Symbol not found for JsAny??, U : ERROR CLASS: Symbol not found for JsAny??> Observable<T>.reduce(operation: (previousValue: U, currentValue: T, currentIndex: Int) -> U, initialValue: U): U

reduceAsync

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

some

suspend fun <T : ERROR CLASS: Symbol not found for JsAny??> Observable<T>.some(predicate: (T) -> Boolean): Boolean

someAsync

fun someAsync(predicate: (T) -> Boolean, options: SubscribeOptions? = definedExternally): Promise<ERROR CLASS: Symbol not found for 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 : ERROR CLASS: Symbol not found for JsAny??> switchMap(transform: (T) -> AsyncIterable<R>): Observable<R>

fun <R : ERROR CLASS: Symbol not found for JsAny??> switchMap(transform: (T) -> JsIterable<R>): Observable<R>

fun <R : ERROR CLASS: Symbol not found for JsAny??> switchMap(transform: (T) -> Promise<R>): Observable<R>

fun <R : ERROR CLASS: Symbol not found for JsAny??> switchMap(transform: (T) -> ReadonlyArray<R>): Observable<R>

fun <R : ERROR CLASS: Symbol not found for JsAny??> switchMap(transform: (T) -> Observable<R>): Observable<R>

take

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

takeUntil

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

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

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

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

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

toArray

suspend fun <T : ERROR CLASS: Symbol not found for JsAny??> Observable<T>.toArray(): ReadonlyArray<T>

toArrayAsync

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