5. 创建 Observable

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

第一个示例

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

var button = document.querySelector('button');
button.addEventListener('click', () => console.log('Clicked!'));

使用 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>

上面例子中的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
  )

使用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);
相关文章
|
JavaScript 前端开发 算法
RxJS系列06:测试 Observable
RxJS系列06:测试 Observable
106 0
|
前端开发 API 开发工具
MobX 源码解析-observable #86
MobX 源码解析-observable #86
116 0
|
JavaScript 前端开发 定位技术
Observable学习笔记
Observable学习笔记
186 0
Observable学习笔记
rxJava中 Subscriber 与Observer
rxJava中 Subscriber 与Observer
217 0
DHL
|
Java API Android开发
EventBus3.1用法详解
EventBus是Android和Java的发布/订阅事件总线。从EventBus3.1开始支持普通Java(非android)项目。GitHub的地址
DHL
250 0
EventBus3.1用法详解
|
JavaScript 前端开发 调度
你会用RxJS吗?【初识 RxJS中的Observable和Observer】
概念 RxJS是一个库,可以使用可观察队列来编写异步和基于事件的程序的库。 RxJS 中管理和解决异步事件的几个关键点: Observable: 表示未来值或事件的可调用集合的概念。 Observer: 是一个回调集合,它知道如何监听 Observable 传递的值。 Subscription: 表示一个 Observable 的执行,主要用于取消执行。 Operators:** 是纯函数,可以使用函数式编程风格来处理具有map、filter、concat、reduce等操作的集合。
147 0
|
前端开发 JavaScript API
Rxjs源码解析(一)Observable
学习一个库最好的方法就是看其源码,理解其 api 的调用原理,用起来自然也就很清楚自己到底在干什么了,秉持着此观念,为了更好地理解 rxjs,抽空将其源码看了一遍 本文章不会刻意涉及概念性的东西,主线就是解读源码,并在恰当的时候给出一些小例子,源码基于 rxjs v7.4.0 版本
334 0
【EventBus】EventBus 使用示例 ( 最简单的 EventBus 示例 )
【EventBus】EventBus 使用示例 ( 最简单的 EventBus 示例 )
202 0
【EventBus】EventBus 使用示例 ( 最简单的 EventBus 示例 )
Rxjs Observable.pipe 传入多个 operators 的执行逻辑分析
Rxjs Observable.pipe 传入多个 operators 的执行逻辑分析
Rxjs Observable.pipe 传入多个 operators 的执行逻辑分析
|
Java
【EventBus】Subscribe 注解分析 ( Subscribe 注解属性 | threadMode 线程模型 | POSTING | MAIN | MAIN_ORDERED | ASYNC)
【EventBus】Subscribe 注解分析 ( Subscribe 注解属性 | threadMode 线程模型 | POSTING | MAIN | MAIN_ORDERED | ASYNC)
725 0