5. 创建 Observable

简介: 第一个示例注册事件监听器的常规写法。var button = document.querySelector('button');button.addEventListener('click', () => console.

第一个示例

注册事件监听器的常规写法。

var button = document.querySelector('button');
button.addEventListener('click', () => console.log('Clicked!'));
AI 代码解读

使用 RxJS 的话,创建一个 observable 来代替(基于最新的Rxjs6版本写法)

<script src='./lib/rxjs.6.3.3.umd.min.js'></script>
<script>
const { fromEvent } = rxjs;

const button = document.querySelector('button');
fromEvent(button, 'click')
  .subscribe(() => console.log('Clicked!'));
</script>
AI 代码解读

上面例子中的fromEvent就是基于Event 建立 Observable,fromEvent 的第一个参数要传入 DOM 对象,第二个参数传入要监听的事件名。
创建 Observable 有很多操作符

img_f70d99869fea8650c939bec4307cf6fa.png
image.png

使用Create操作符从头开始创建一个Observable, 这个接收一个回调函数,把observer作为参数

  // Observer 是一个对象,这个对象具有三个方法,分别是 next, error, complete
  // 建立 Observable 最简单方法是用 create 方法
  // create 接收一个回调函数,把observer作为参数
  const observer = {
    next: value => {
      console.log(`observer:` + value)
    },
    error: error => {
      console.log('Error:', error);
    },
    complete: () => {
      console.log('complete');
    }
  }

  var observable = rxjs.Observable
    .create(observer => {
      observer.next('Jerry');
      observer.next('Anna');
      observer.complete();
      observer.next('not work');
    })

  // 建立观察者来订阅 observable
  // 订阅一个 Observable 就像是执行一个 function
  observable.subscribe(
    observer
  )
AI 代码解读

使用from操作符将对象、字符串,数组,promise 等其他类型转换为Observable,请自己敲一遍看结果。

  const {from} = rxjs;

  function f() {
    return from(arguments);
  }

  const observer = {
    next: value => {
      console.log('Next: ' + value);
    },
    error: error => {
      console.log('Error:', error);
    },
    complete: () => {
      console.log('Complete');
    }
  }

  // Array Like Object
  f(1, 2, 3).subscribe(observer);

  // string
  from('foo').subscribe(observer);

  // Set, any iterable object
  const s = new Set(['foo', window]);
  from(s).subscribe(observer);

  // Promise
  const source = from(new Promise((resolve, reject) => {
      setTimeout(() => {
        resolve('Hello RxJS!');
      }, 3000)
    }))

  source.subscribe(observer);
AI 代码解读
目录
打赏
0
0
0
0
4
分享
相关文章
原始边列表转换为邻接矩阵
【6月更文挑战第23天】在图论和网络分析中,图由节点和边构成,可以用邻接矩阵表示。Python代码展示了如何从边列表`(0, 1), (0, 2), (1, 2), (2, 3)`转换成邻接矩阵,涉及有向/无向图、权重处理及稀疏矩阵优化。此外,还包括了使用NetworkX库进行图可视化以及将邻接矩阵逆向转换为边列表。这些方法在处理大规模图数据时尤其重要,如社交网络分析和交通规划。
144 1
百度地图API开发:停车场分布标注和检索静态版
百度地图API开发:停车场分布标注和检索静态版
246 0
AnalyticDB MySQL升级为湖仓一体架构:从湖到仓,打造云原生一站式数据分析平台
AnalyticDB MySQL湖仓版同时支持低成本离线处理和高性能在线分析,适合ETL/BI报表/交互式查询/APP应用等多场景,并可无缝替换CDH/TDH/Databricks/Presto/Spark/Hive等
Kotlin常用Collection集合操作整理
本篇记录了`Kotlin`常用集合的相关操作,用以熟练使用`Kotlin`里的相关集合。集合接口与相关函数位于` kotlin.collections` 包中。
429 0
小白新手一篇看懂PolarDB-X
简要讲述什么是PolarDB-X,以及基础安装,与srpingboot项目整合等
小白新手一篇看懂PolarDB-X
基于docker部署redis多主多从集群
在docker中部署redis多主多从集群,准备部署三对一主一从服务,共6个

热门文章

最新文章

AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问