zoukankan      html  css  js  c++  java
  • [RxJS] Reactive Programming

    First thing need to understand is, Reactive programming is dealing with the event stream.

    Event streams happens overtime, which not stay in the memory.

    For example, the array we have:

    var source = ['1', '1', 'foo', '2', '3', '5', 'bar', '8', '13'];

    Which is stay in the momery. 

    But the stream we have:

    let logic = Rx.Observable.interval(400).take(9)
      .map( (i) => {
        let val = ['1', '1', 'foo', '2', '3', '5', 'bar', '8', '13'][i]
        return parseInt(val, 10);
    })

    Which happens overtime, every 400ms it return an Interge if possible.

    So the main difference between array stay in memory and the events streams is array already stay in memory and the streams happens overtime.

    But the nice things about the stream is we can still use the methods we have for array:

    let logic = Rx.Observable.interval(400).take(9)
      .map( (i) => {
        let val = ['1', '1', 'foo', '2', '3', '5', 'bar', '8', '13'][i]
        return parseInt(val, 10);
    })
      .filter( (number) => {
        return !isNaN(number)
      })
      .reduce( (acc, y) => {
         return acc + y;
      } );
    
    let effect = logic.subscribe( (number) => {
      console.log(number);
    });
  • 相关阅读:
    21.扩展
    20.嵌套类型
    19.类型转换
    18.错误处理
    17.可选链
    16.ARC
    15.析构函数
    14.构造函数
    13.继承
    12.下标
  • 原文地址:https://www.cnblogs.com/Answer1215/p/5251686.html
Copyright © 2011-2022 走看看