Files

T

fargo 1a822493ba format: apply repo prettier (3.8.1) to the folded skills tree

963 markdown files reformatted with the repository's pinned prettier so
pnpm format:check covers the folded tree like every other repo file.

The formatter's embedded-language pass also normalized code fences
(TS semicolons, closed HTML tags in examples, lowercased CSS hex colors,
one renumbered list that skipped an index). Alphanumeric token deltas vs
the fold commit were audited file-by-file; all are formatter-equivalent
markup normalizations plus the four sanitized skills.

2026-08-19 14:37:17 -05:00

4.6 KiB

Raw Blame History

category
@RxJS

useExtractedObservable

Use an RxJS Observable as extracted from one or more composables, return a ref, and automatically unsubscribe from it when the component is unmounted.

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

Supports signatures that match all overloads of watch.

Usage

import { useExtractedObservable } from '@vueuse/rxjs';
import ObservableSocket from 'observable-socket';
import { computed } from 'vue';
import { makeSocket, useUser } from '../some/lib/func';

// setup()
const user = useUser();
const lastMessage = useExtractedObservable(
  user,
  (u) => ObservableSocket.create(makeSocket(u.id)).down,
);

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).

import { useExtractedObservable } from '@vueuse/rxjs';
import { interval } from 'rxjs';
import { mapTo, scan, startWith, tap } from 'rxjs/operators';
import { shallowRef } from 'vue';

// setup()
const start = shallowRef(0);

const count = useExtractedObservable(
  start,
  (start) => {
    return interval(1000).pipe(
      mapTo(1),
      startWith(start),
      scan((total, next) => next + total),
      tap((n) => {
        if (n === 10) throw new Error('oops');
      }),
    );
  },
  {
    onError: (err) => {
      console.log(err.message); // "oops"
    },
  },
);

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

import { useExtractedObservable } from '@vueuse/rxjs';
import { interval } from 'rxjs';
import { mapTo, scan, startWith, takeWhile } from 'rxjs/operators';
import { shallowRef } from 'vue';

// setup()
const start = shallowRef(0);

const count = useExtractedObservable(
  start,
  (start) => {
    return interval(1000).pipe(
      mapTo(1),
      startWith(start),
      scan((total, next) => next + total),
      takeWhile((num) => num < 10),
    );
  },
  {
    onComplete: () => {
      console.log('Done!');
    },
  },
);

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

import { useExtractedObservable } from '@vueuse/rxjs';
import { interval } from 'rxjs';
import { mapTo, scan, startWith, takeWhile } from 'rxjs/operators';
import { shallowRef } from 'vue';

// setup()
const start = shallowRef<number>();

const count = useExtractedObservable(
  start,
  (start) => {
    return interval(1000).pipe(
      mapTo(1),
      startWith(start),
      scan((total, next) => next + total),
      takeWhile((num) => num < 10),
    );
  },
  {},
  {
    immediate: false,
  },
);

Type Declarations

export interface UseExtractedObservableOptions<E> extends UseObservableOptions<E> {
  onComplete?: () => void;
}
export declare function useExtractedObservable<
  T extends MultiWatchSources,
  E,
  Immediate extends Readonly<boolean> = false,
>(
  sources: [...T],
  extractor: WatchExtractedObservableCallback<MapSources<T>, MapOldSources<T, Immediate>, E>,
  options?: UseExtractedObservableOptions<E>,
  watchOptions?: WatchOptions<Immediate>,
): Readonly<ShallowRef<E>>;
export declare function useExtractedObservable<
  T extends Readonly<MultiWatchSources>,
  E,
  Immediate extends Readonly<boolean> = false,
>(
  sources: T,
  extractor: WatchExtractedObservableCallback<MapSources<T>, MapOldSources<T, Immediate>, E>,
  options?: UseExtractedObservableOptions<E>,
  watchOptions?: WatchOptions<Immediate>,
): Readonly<ShallowRef<E>>;
export declare function useExtractedObservable<T, E, Immediate extends Readonly<boolean> = false>(
  sources: WatchSource<T>,
  extractor: WatchExtractedObservableCallback<T, Immediate extends true ? T | undefined : T, E>,
  options?: UseExtractedObservableOptions<E>,
  watchOptions?: WatchOptions<Immediate>,
): Readonly<ShallowRef<E>>;
export declare function useExtractedObservable<
  T extends object,
  E,
  Immediate extends Readonly<boolean> = false,
>(
  sources: T,
  extractor: WatchExtractedObservableCallback<T, Immediate extends true ? T | undefined : T, E>,
  options?: UseExtractedObservableOptions<E>,
  watchOptions?: WatchOptions<Immediate>,
): Readonly<ShallowRef<E>>;

4.6 KiB Raw Blame History

useExtractedObservable

Usage

Type Declarations

4.6 KiB

Raw Blame History