rxjs简单的Observable用例

import React from ‘react‘;
import { Observable } from ‘rxjs‘;

const FlowPage = () => {
  
  const onSubscribe = observer => {
    observer.next(1);
    observer.next(2);
    observer.next(3);
  }

  // 创建一个发布者
  // Observable是一个特殊类，它接受一个处理Observer的函数
  // 而Observer就是一个普通的对象，
  // 对于Observer对象要求：它必须包含一个名为next的属性（是一个函数）
  // next用于接收被推过来的数据
  const source$ = new Observable(onSubscribe);

  // 参数就是观察者对象
  const theObserver = {
    next : item => console.log(item)
  }

  // 一个观察者调用Observable对象的subscribe函数
  source$.subscribe(theObserver)

  return <h1>rxjs学习</h1>;
};

export default FlowPage;