zoukankan      html  css  js  c++  java
  • [rxjs] Shares a single subscription -- publish()

    If have an observable and you subscribe it twice, those tow subscritions have no connection. 

    console.clear();
    var Observable = Rx.Observable;
    var _id = 1;
    
    var source = Observable.create(function(Observe){
      var myId = _id++;
      Observe.onNext('Observable ' + myId);
      setTimeout(function(){
        Observe.onNext('Observable... ' + myId);
        Observe.onCompleted();
      }, 1000);
    });
    
    var subscrition1 = source.subscribe(function onNext(x){
      console.log('Observable 1: ' + x);
    });
    
    var subscrition2 = source.subscribe(function onNext(x){
      console.log('Observable 2: ' + x);
    });

    Result:

    /*"Observable 1: Observable 1"
    "Observable 2: Observable 2"
    "Observable 1: Observable... 1"
    "Observable 2: Observable... 2"*/

    publish():

    Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence.

    console.clear();
    var Observable = Rx.Observable;
    var _id = 1;
    
    var source = Observable.create(function(Observe){
      var myId = _id++;
      Observe.onNext('Observable ' + myId);
      setTimeout(function(){
        Observe.onNext('Observable... ' + myId);
        Observe.onCompleted();
      }, 1000);
    });
    var published = source.publish();
    
    var subscrition1 = published.subscribe(function onNext(x){
      console.log('Observable 1: ' + x);
    });
    
    var subscrition2 = published.subscribe(function onNext(x){
      console.log('Observable 2: ' + x);
    });
    
    var connection = published.connect();

    Results:

    /*
    "Observable 1: Observable 1"
    "Observable 2: Observable 1"
    "Observable 1: Observable... 1"
    "Observable 2: Observable... 1"
    */

    You can see the result just have one single subscrition then.

    You can dispose the connection:

    connection.dispose();

    Results:

    /*"Observable 1: Observable 1"
    "Observable 2: Observable 1"*/

    There is a problem when you connect the published observables at different place.

    var Observable = Rx.Observable;
    var _id = 1;
    
    var source = Observable.create(function(Observe){
      var myId = _id++;
      Observe.onNext('Observable ' + myId);
      setTimeout(function(){
        Observe.onNext('Observable... ' + myId);
        Observe.onCompleted();
      }, 1000);
    });
    var published = source.publish();
    var connection = published.connect();
    
    var subscrition1 = published.subscribe(function onNext(x){
      console.log('Observable 1: ' + x);
    });
    
    var subscrition2 = published.subscribe(function onNext(x){
      console.log('Observable 2: ' + x);
    });
    
    //var connection = published.connect();

    Results:

    /*"Observable 1: Observable... 1"
    "Observable 2: Observable... 1"*/

    If we move the connect() funciton up before subscribe(). Then we missed the very first console.log(); It means connection is already start, but no one subscribe it yet.

    Therefore, we don't use publish() funciton alone, more than often we use publish().refCount() function together.

  • 相关阅读:
    Github进不去解决方法
    微信小程序中使用iconfont的方法
    curl实现SFTP上传下载文件
    curl实现SFTP上传下载文件
    curl不支持sftp的解决方法
    sscanf遇到回车换行认为字符串结束,怎样让它忽略这些回车换行继续搜索整个字符串?
    史上最全阿里 Java 面试题总结及答案
    VS Code的Error: Running the contributed command: ‘_workbench.downloadResource‘ failed解决
    云锵投资 2021 年 07 月简报
    看完段永平的100条思考,我终于悟出他为何这么牛…(转载)
  • 原文地址:https://www.cnblogs.com/Answer1215/p/4754960.html
Copyright © 2011-2022 走看看