• share
    • 签名: share(): Observable
  • 在多个订阅者间共享源 observable 。
    • 示例
      • 示例 1: 多个订阅者共享源 observable
  • 相关食谱
  • 其他资源
  • 其他资源

    share

    签名: share(): Observable

    在多个订阅者间共享源 observable 。

    :bulb: share 就像是使用了 Subject 和 refCount 的 multicast！

    share - 图2

    示例

    示例 1: 多个订阅者共享源 observable

    ( jsBin |
    jsFiddle )

    1. import { timer } from 'rxjs/observable/timer';
    2. import { tap, mapTo, share } 'rxjs/operators';
    4. // 1秒后发出值
    5. const source = timer(1000);
    6. // 输出副作用，然后发出结果
    7. const example = source.pipe(
    8.   tap(() => console.log('***SIDE EFFECT***')),
    9.   mapTo('***RESULT***')
    10. );
    12. /*
    13.   ***不共享的话，副作用会执行两次***
    14.   输出: 
    15.   "***SIDE EFFECT***"
    16.   "***RESULT***"
    17.   "***SIDE EFFECT***"
    18.   "***RESULT***"
    19. */
    20. const subscribe = example.subscribe(val => console.log(val));
    21. const subscribeTwo = example.subscribe(val => console.log(val));
    23. // 在多个订阅者间共享 observable
    24. const sharedExample = example.pipe(share());
    25. /*
    26.    ***共享的话，副作用只执行一次***
    27.   输出:
    28.   "***SIDE EFFECT***"
    29.   "***RESULT***"
    30.   "***RESULT***"
    31. */
    32. const subscribeThree = sharedExample.subscribe(val => console.log(val));
    33. const subscribeFour = sharedExample.subscribe(val => console.log(val));

    相关食谱

    • 进度条
    • 游戏循环

    其他资源

    其他资源

    • share :newspaper: - 官方文档
    • 使用 share 共享流 :video_camera: :dollar: - John Linquist

    :file_folder: 源码: https://github.com/ReactiveX/rxjs/blob/master/src/internal/operators/share.ts