kotlin-web/web.observable

Package-level declarations

Types

typealias SubscribeCallback<T> = (subscriber: Subscriber<T>) -> Unit

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>

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

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

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

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

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

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

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