zoukankan      html  css  js  c++  java
  • [RxJS] Marble diagrams in ASCII form

    There are many operators available, and in order to understand them we need to have a simple way of communicating how they transform a source Observable into a result Observable over time. Throughout this course we are going to see the so-called marble diagrams.

    var foo = Rx.Observable.interval(1000);
    
    /*
    
    foo: ---0---1---2---3--...
            multiplyBy(2)
    bar: ---0---2---4---6--...
    
    */
    
    function multiplyBy(multiplier) {
      var source = this;
      var result = Rx.Observable.create(function subscribe(observer) {
        source.subscribe(
          function (x) { observer.next(x * multiplier); },
          function (err) { observer.error(err); },
          function () { observer.complete(); }
        );
      });
      return result;
    }
    
    Rx.Observable.prototype.multiplyBy = multiplyBy;
    
    var bar = foo.multiplyBy(2);
    
    bar.subscribe(
      function (x) { console.log('next ' + x); },
      function (err) { console.log('error ' + err); },
      function () { console.log('done'); },
    );
  • 相关阅读:
    Notes | 基于医疗知识图谱的问答系统实践
    Notes | 知识图谱介绍与Neo4J实战
    从jvm源码看synchronized
    Kakfa基础
    volatile
    JVM垃圾收集器
    原码,反码,补码
    mini设计模式
    xshell提示采购解决方法
    应试必备算法
  • 原文地址:https://www.cnblogs.com/Answer1215/p/5524497.html
Copyright © 2011-2022 走看看