zoukankan      html  css  js  c++  java
  • [RxJS] Combination operators: concat, startWith

    Some Observables may complete, and we may want to append another Observable to the one which just completed. This lesson teaches you how to use the concat() operator for either appending or prepending, and how the shortcut operator startWith() is an easy way of prepending values to an Observable.

     concat(observalbe): wait until the first observalbe complete than append the scond observable result. 
    var foo = Rx.Observable.interval(100).take(7);
    var more = Rx.Observable.of(10,11,12,13,14);
    
    /*
    --0--1--2--3--4--5--6--7-...
        take(7)
                         (10,11,12,13,14|)       (more)
    --0--1--2--3--4--5--6|                       (foo)
       concat
    --0--1--2--3--4--5--6|(10,11,12,13,14)|
    */
    
    var bar = foo.concat(more);
    
    bar.subscribe(
      function (x) { console.log('next ' + x); },
      function (err) { console.log('error ' + err); },
      function () { console.log('done'); },
    );
    
      /*
      "next 0"
    "next 1"
    "next 2"
    "next 3"
    "next 4"
    "next 5"
    "next 6"
    "next 10"
    "next 11"
    "next 12"
    "next 13"
    "next 14"
    "done"
      */

    Observable.concat(first$, second$): static way to concat:

    var foo = Rx.Observable.interval(100).take(7);
    var more = Rx.Observable.of(10,11,12,13,14);
    
    /*
    --0--1--2--3--4--5--6--7-...
        take(7)
                         (10,11,12,13,14|)       (more)
    --0--1--2--3--4--5--6|                       (foo)
       concat
    --0--1--2--3--4--5--6|(10,11,12,13,14)|
    */
    
    var bar = Rx.Observable.concat(foo, more);
    
    bar.subscribe(
      function (x) { console.log('next ' + x); },
      function (err) { console.log('error ' + err); },
      function () { console.log('done'); },
    );

    The code return the same result as the code showing before.

    startWith(value):

    var foo = Rx.Observable.interval(100).take(7);
    
    
    /*
    --0--1--2--3--4--5--6--7-...
        take(7)
    --0--1--2--3--4--5--6|                       (foo)
       startWith('more')
    ('more')--0--1--2--3--4--5--6|
    */
    
    var bar = foo.startWith('more');
    
    bar.subscribe(
      function (x) { console.log('next ' + x); },
      function (err) { console.log('error ' + err); },
      function () { console.log('done'); },
    );
    
      /*
    "next more"
    "next 0"
    "next 1"
    "next 2"
    "next 3"
    "next 4"
    "next 5"
    "next 6"
    "done"
      */
  • 相关阅读:
    【长安十二时辰】 刺客信条风格剪辑
    【Oracle 触发器】(6)触发器应用场景--数据的备份和同步
    【Oracle 触发器】(5)触发器应用场景--数据库的审计
    银行窗口取号系统,共享数据的线程安全性
    模板方法
    创建线程时如果既传入了runnable对象,又继承thread重写了run方法,会执行哪里的代码
    启动线程用start方法而不是run方法
    java的回调
    java中的闭包
    静态内部类
  • 原文地址:https://www.cnblogs.com/Answer1215/p/5528430.html
Copyright © 2011-2022 走看看