@vueuse/rxjs

这是 VueUse 的插件，支持以自然的方式使用 RxJS。

¥This is an add-on of VueUse, enabling a natural way of using RxJS.

安装

¥Install

npm i @vueuse/rxjs rxjs

函数

¥Functions

• from — ¥from / fromEvent
• toObserver — sugar 函数将 ref 转换为 RxJS 观察者。
• useExtractedObservable — 使用从一个或多个可组合项中提取的 RxJS Observable，返回 ref，并在卸载组件时自动取消订阅。
• useObservable — 使用 RxJS Observable，返回 ref，并在组件卸载时自动取消订阅。
• useSubject — 将 RxJS Subject 绑定到 ref 并以双向方式传播值更改。
• useSubscription — 使用 RxJS Subscription 无需担心取消订阅或造成内存泄漏。
• watchExtractedObservable — 观察从一个或多个可组合项中提取的 RxJS Observable 的值。

示例

¥Example

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'

const BASE_URL = 'https://jsonplaceholder.typicode.com'
const button = ref<HTMLButtonElement>(null)

const posts = useObservable(
  fromEvent(button, 'click').pipe(
    mergeMap(() => ajax.getJSON(`${BASE_URL}/posts`).pipe(
      concatAll(),
      take(4),
      mergeMap(({ id, userId, title }) => forkJoin({
        id: of(id),
        comments: ajax.getJSON(`${BASE_URL}/posts/${id}/comments`).pipe(
          map(comments => comments.length),
        ),
        username: ajax.getJSON(`${BASE_URL}/users/${userId}`).pipe(
          pluck('username'),
        ),
      }), 2),
      scan((acc, curr) => [...acc, curr], []),
    )),
  ),
)

许可

¥License

MIT 许可证 © 2019-PRESENT Anthony Fu

¥MIT License © 2019-PRESENT Anthony Fu