watchExtractedObservable

观察从一个或多个可组合项中提取的 RxJS Observable 的值。

¥Watch the values of an RxJS Observable as extracted from one or more composables.

自动取消订阅可观察到的更改，并在卸载组件时自动取消订阅。

¥Automatically unsubscribe on observable change, and automatically unsubscribe from it when the component is unmounted.

支持 watch 的所有重载。

¥Supports all overloads of watch. Available in the @vueuse/rxjs add-on.

用法

¥Usage

TypeScript

import { watchExtractedObservable } from '@vueuse/rxjs'
import { computed, ref } from 'vue'
import { AudioPlayer } from '../my/libs/AudioPlayer'

// setup()

const audio = ref<HTMLAudioElement>()
const player = computed(() => (audio.value ? new AudioPlayer(audio) : null))
const state = reactive({
  progress: 0,
})

watchExtractedObservable(player, p => p.progress$, (percentage) => {
  state.progress = percentage * 100
})

import { watchExtractedObservable } from '@vueuse/rxjs'
import { computed, ref } from 'vue'
import { AudioPlayer } from '../my/libs/AudioPlayer'
// setup()
const audio = ref()
const player = computed(() => (audio.value ? new AudioPlayer(audio) : null))
const state = reactive({
  progress: 0,
})
watchExtractedObservable(
  player,
  (p) => p.progress$,
  (percentage) => {
    state.progress = percentage * 100
  },
)

如果你想要向可能出错的 Observable 添加自定义错误处理，你可以提供可选的 onError 配置。如果没有这个，RxJS 会将所提供的 Observable 中的任何错误视为 "未处理的错误"，并将其扔到新的调用堆栈中并报告给 window.onerror（如果碰巧在 Node 中，则报告给 process.on('error')）。

¥If you want to add custom error handling to an Observable that might error, you can supply an optional onError configuration. Without this, RxJS will treat any error in the supplied Observable as an "unhandled error" and it will be thrown in a new call stack and reported to window.onerror (or process.on('error') if you happen to be in Node).

如果你需要在监视的可观察对象完成时附加特殊行为，你还可以提供可选的 onComplete 配置。

¥You can also supply an optional onComplete configuration if you need to attach special behavior when the watched observable completes.

TypeScript

import { watchExtractedObservable } from '@vueuse/rxjs'
import { computed, ref } from 'vue'
import { AudioPlayer } from '../my/libs/AudioPlayer'

// setup()

const audio = ref<HTMLAudioElement>()
const player = computed(() => (audio.value ? new AudioPlayer(audio) : null))
const state = reactive({
  progress: 0,
})

watchExtractedObservable(player, p => p.progress$, (percentage) => {
  state.progress = percentage * 100
}, {
  onError: (err: unknown) => {
    console.error(err)
  },
  onComplete: () => {
    state.progress = 100 // or 0, or whatever
  },
})

import { watchExtractedObservable } from '@vueuse/rxjs'
import { computed, ref } from 'vue'
import { AudioPlayer } from '../my/libs/AudioPlayer'
// setup()
const audio = ref()
const player = computed(() => (audio.value ? new AudioPlayer(audio) : null))
const state = reactive({
  progress: 0,
})
watchExtractedObservable(
  player,
  (p) => p.progress$,
  (percentage) => {
    state.progress = percentage * 100
  },
  {
    onError: (err) => {
      console.error(err)
    },
    onComplete: () => {
      state.progress = 100 // or 0, or whatever
    },
  },
)

如果需要，你还可以传递 watch 选项作为最后一个参数：

¥If you want, you can also pass watch options as the last argument:

TypeScript

import { watchExtractedObservable } from '@vueuse/rxjs'
import { computed, ref } from 'vue'
import { AudioPlayer } from '../my/libs/AudioPlayer'

// setup()

const audio = ref<HTMLAudioElement>()
const player = computed(() => (audio.value ? new AudioPlayer(audio) : null))
const state = reactive({
  progress: 0,
})

watchExtractedObservable(player, p => p.progress$, (percentage) => {
  state.progress = percentage * 100
}, {
  onError: (err: unknown) => {
    console.error(err)
  }
}, {
  immediate: true
})

import { watchExtractedObservable } from '@vueuse/rxjs'
import { computed, ref } from 'vue'
import { AudioPlayer } from '../my/libs/AudioPlayer'
// setup()
const audio = ref()
const player = computed(() => (audio.value ? new AudioPlayer(audio) : null))
const state = reactive({
  progress: 0,
})
watchExtractedObservable(
  player,
  (p) => p.progress$,
  (percentage) => {
    state.progress = percentage * 100
  },
  {
    onError: (err) => {
      console.error(err)
    },
  },
  {
    immediate: true,
  },
)

类型声明

显示类型声明

export type OnCleanup = (cleanupFn: () => void) => void
export type WatchExtractedObservableCallback<
  Value,
  OldValue,
  ObservableElement,
> = (
  value: NonNullable<Value>,
  oldValue: OldValue,
  onCleanup: OnCleanup,
) => Observable<ObservableElement>
export interface WatchExtractedObservableOptions {
  onError?: (err: unknown) => void
  onComplete?: () => void
}
export declare function watchExtractedObservable<
  T extends MultiWatchSources,
  E,
  Immediate extends Readonly<boolean> = false,
>(
  sources: [...T],
  extractor: WatchExtractedObservableCallback<
    MapSources<T>,
    MapOldSources<T, Immediate>,
    E
  >,
  callback: (snapshot: E) => void,
  subscriptionOptions?: WatchExtractedObservableOptions,
  watchOptions?: WatchOptions<Immediate>,
): WatchStopHandle
export declare function watchExtractedObservable<
  T extends Readonly<MultiWatchSources>,
  E,
  Immediate extends Readonly<boolean> = false,
>(
  source: T,
  extractor: WatchExtractedObservableCallback<
    MapSources<T>,
    MapOldSources<T, Immediate>,
    E
  >,
  callback: (snapshot: E) => void,
  subscriptionOptions?: WatchExtractedObservableOptions,
  watchOptions?: WatchOptions<Immediate>,
): WatchStopHandle
export declare function watchExtractedObservable<
  T,
  E,
  Immediate extends Readonly<boolean> = false,
>(
  source: WatchSource<T>,
  extractor: WatchExtractedObservableCallback<
    T,
    Immediate extends true ? T | undefined : T,
    E
  >,
  callback: (snapshot: E) => void,
  subscriptionOptions?: WatchExtractedObservableOptions,
  watchOptions?: WatchOptions<Immediate>,
): WatchStopHandle
export declare function watchExtractedObservable<
  T extends object,
  E,
  Immediate extends Readonly<boolean> = false,
>(
  source: T,
  extractor: WatchExtractedObservableCallback<
    T,
    Immediate extends true ? T | undefined : T,
    E
  >,
  callback: (snapshot: E) => void,
  subscriptionOptions?: WatchExtractedObservableOptions,
  watchOptions?: WatchOptions<Immediate>,
): WatchStopHandle

源代码

源代码 • 文档

变更日志

No recent changes