@vueuse/rxjs
Advanced tools
Comparing version
@@ -0,4 +1,4 @@ | ||
import { MaybeRef, MultiWatchSources, MapSources, MapOldSources } from '@vueuse/shared'; | ||
import { ObservableInput, Observable, NextObserver, BehaviorSubject, Subject, Unsubscribable } from 'rxjs'; | ||
import { Ref, WatchOptions, WatchStopHandle, WatchSource } from 'vue-demi'; | ||
import { MaybeRef, MultiWatchSources, MapSources, MapOldSources } from '@vueuse/shared'; | ||
@@ -10,2 +10,11 @@ declare function from<T>(value: ObservableInput<T> | Ref<T>, watchOptions?: WatchOptions): Observable<T>; | ||
interface UseObservableOptions<I> { | ||
onError?: (err: any) => void; | ||
/** | ||
* The value that should be set if the observable has not emitted. | ||
*/ | ||
initialValue?: I | undefined; | ||
} | ||
declare function useObservable<H, I = undefined>(observable: Observable<H>, options?: UseObservableOptions<I | undefined>): Readonly<Ref<H | I>>; | ||
type OnCleanup = (cleanupFn: () => void) => void; | ||
@@ -22,11 +31,2 @@ type WatchExtractedObservableCallback<Value, OldValue, ObservableElement> = (value: NonNullable<Value>, oldValue: OldValue, onCleanup: OnCleanup) => Observable<ObservableElement>; | ||
interface UseObservableOptions<I> { | ||
onError?: (err: any) => void; | ||
/** | ||
* The value that should be set if the observable has not emitted. | ||
*/ | ||
initialValue?: I | undefined; | ||
} | ||
declare function useObservable<H, I = undefined>(observable: Observable<H>, options?: UseObservableOptions<I | undefined>): Readonly<Ref<H | I>>; | ||
interface UseExtractedObservableOptions<E> extends UseObservableOptions<E> { | ||
@@ -33,0 +33,0 @@ onComplete?: () => void; |
{ | ||
"name": "@vueuse/rxjs", | ||
"version": "11.0.3", | ||
"version": "11.1.0", | ||
"description": "Enables RxJS reactive functions in Vue", | ||
@@ -41,5 +41,5 @@ "author": "Anthony Fu <https://github.com/antfu>", | ||
"dependencies": { | ||
"@vueuse/shared": "11.0.3", | ||
"@vueuse/shared": "11.1.0", | ||
"vue-demi": ">=0.14.10" | ||
} | ||
} |
@@ -32,6 +32,6 @@ # @vueuse/rxjs | ||
import { from, fromEvent, useObservable } from '@vueuse/rxjs' | ||
import { ref } from 'vue' | ||
import { forkJoin, of } from 'rxjs' | ||
import { ajax } from 'rxjs/ajax' | ||
import { concatAll, map, mergeMap, pluck, scan, take } from 'rxjs/operators' | ||
import { ref } from 'vue' | ||
@@ -38,0 +38,0 @@ const BASE_URL = 'https://jsonplaceholder.typicode.com' |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
+ Added
- Removed
Updated