JavaScript Rxjs mergeMap 的使用场合

 更新时间:2022年07月01日 10:49:18   作者:​ JerryWang_sap   ​  
这篇文章主要介绍了JavaScript Rxjs mergeMap 的使用场合,mergeMap 接收一个函数作为输入参数,这个函数的输入参数就是通过 pipe 链接 mergeMap 的 Observable 里包含的元素

注意:

  • flatMap 是 mergeMap 的别名。
  • 如果一次只能激活一个内部订阅,请使用 switchMap.
  • 如果内部 observables 的发射和订阅顺序很重要,请使用 concatMap.

当需要展平内部 observable 但想要手动控制内部订阅的数量时,是 mergeMap 极佳的使用场合。

例如,当使用 switchMap 时,每个内部订阅在源发出时完成,即任意时间段只允许一个活动的内部订阅。相比之下,mergeMap 允许同时激活多个内部订阅。因此,mergeMap 最常见的用例之一是不应取消的请求,这些请求被认为是写入而不是读取。

一个典型的例子就是 SAP 电商云购物车里不同行项目的金额,可以并行地进行增减操作。

请注意,如果这些写入必须保持顺序,则 concatMap 是更好的选择。比如数据库的写操作。

由于 mergeMap 一次维护多个活动的内部订阅,因此可能会由于长期存在的内部订阅造成内存泄漏。一个基本的例子是,如果使用内部计时器或 dom 事件流映射到可观察对象。在这些情况下,如果仍然希望使用 mergeMap,一个好办法是利用另一个运算符来管理内部订阅的完成,比如考虑 take 或 takeUntil。当然还可以使用 concurrent 参数限制一次活动内部订阅的数量。

看一个例子:

import { fromEvent, of } from 'rxjs';
import { mergeMap, delay } from 'rxjs/operators';
// faking network request for save
const saveLocation = location => {
  return of(location).pipe(delay(500));
};
// streams
const click$ = fromEvent(document, 'click');

click$
  .pipe(
    mergeMap((e: MouseEvent) => {
      return saveLocation({
        x: e.clientX,
        y: e.clientY,
        timestamp: Date.now()
      });
    })
  )
  // Saved! {x: 98, y: 170, ...}
  .subscribe(r => console.log('Saved!', r));

saveLocation 是一个函数,它能把任何传入的输入参数,包裹成一个 Observable,并且这个 Observable 并不是立即 emit 数据,而是延迟 500 毫秒。

mergeMap 接收一个函数作为输入参数,这个函数的输入参数就是通过 pipe 链接 mergeMap 的 Observable 里包含的元素,即 MouseEvent;project 返回的数据类型是一个新的 Observable,包含了屏幕点击的 X 和 Y 坐标以及当前时间戳。

最后产生的输出: 

到此这篇关于JavaScript Rxjs mergeMap 的使用场合的文章就介绍到这了,更多相关JS Rxjs mergeMap 内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • npm install 、npm install --save 和 npm install --save-dev的区别介绍

    npm install 、npm install --save 和&n

    这篇文章主要介绍了npm install 、npm install --save 和 npm install --save-dev的区别介绍,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2023-04-04
  • JS实现简单的点赞与踩功能示例

    JS实现简单的点赞与踩功能示例

    这篇文章主要介绍了JS实现简单的点赞与踩功能,涉及javascript针对页面元素动态操作相关实现技巧,需要的朋友可以参考下
    2018-12-12
  • 使用微信SDK自定义分享的方法

    使用微信SDK自定义分享的方法

    这篇文章主要介绍了使用微信SDK自定义分享的方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-07-07
  • javascript中call,apply,callee,caller用法实例分析

    javascript中call,apply,callee,caller用法实例分析

    这篇文章主要介绍了javascript中call,apply,callee,caller用法,结合实例形式分析了javascript中call,apply,callee,caller功能、使用方法及相关操作注意事项,需要的朋友可以参考下
    2019-07-07
  • JS实现的计数排序与基数排序算法示例

    JS实现的计数排序与基数排序算法示例

    这篇文章主要介绍了JS实现的计数排序与基数排序算法,结合实例形式简单分析了计数排序与基数排序的原理与JS实现技巧,需要的朋友可以参考下
    2017-12-12
  • JS对象添加属性和方法的多种方式

    JS对象添加属性和方法的多种方式

    本文介绍了如何使用JavaScript对象添加属性和方法,通过实例演示了如何给对象添加属性,以及如何在对象中定义方法,具有一定的参考价值,感兴趣的可以了解一下
    2023-08-08
  • JavaScript 编程引入命名空间的方法

    JavaScript 编程引入命名空间的方法

    JavaScript 编程引入命名空间的方法...
    2007-06-06
  • 浅谈一个webpack构建速度优化误区

    浅谈一个webpack构建速度优化误区

    这篇文章主要介绍了浅谈一个webpack构建速度优化误区,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2019-06-06
  • Javascript实现登录框拖拽效果

    Javascript实现登录框拖拽效果

    这篇文章主要为大家详细介绍了Javascript实现登录框拖拽效果,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-10-10
  • uniapp开发H5使用formData上传文件解决方案

    uniapp开发H5使用formData上传文件解决方案

    我们很多时候上传文件就是使用FormData,然而uniapp默认不支持FormData类型数据的上传,下面这篇文章主要给大家介绍了关于uniapp开发H5使用formData上传文件的相关资料,需要的朋友可以参考下
    2023-12-12

最新评论