zoukankan      html  css  js  c++  java
  • [RxJS] AsyncSubject

    AsyncSubject emit the last value of a sequence only if the sequence completed. This value is then cached forever, and any other Observer that subscribes after the value has been emmitted will receive it right away.

    AsyncSubject is convenient for asynchronous operations that return a single value, such as Ajax requests.

    var subject = new Rx.AsyncSubject();
    var delayedRange = Rx.Observable.range(0,5).delay(1000);
    
    delayedRange.subscribe(subject);
    
    //----[0,1,2,3,4]|
    //  AsyncSubject
    //----4|
    
    subject.subscribe(
      function onNext(item) { console.log('Value:', item); },
      function onError(err) { console.log('Error:', err); },
      function onCompleted() { console.log('Completed.'); }
    )
    
    /*
    "Value:"
    4
    "Completed."
    */

    A more useful example:

    function getProducts(url){
      var subject;
      
      return Rx.Observable.create(function(observer){
        //If first time, then create AsyncSubject
        if(!subject){
          subject = new Rx.AsyncSubject();
          //Subscribe to subject
          Rx.DOM.get(url).subscribe(subject);
        }
        //If subject already exists, then just subscribe observer
        return subject.subscribe(observer);
      })
    }
    
    var products = getProducts('/products');
    
    // Will trigger request and receive the response when read
    products.subscribe(
      function onNext(result) {console.log('Result 1: ', result.response)},
      function onError(error) {console.log('ERROR', error)}
    );
    
    // Will receive the result immediately because it is cached
    setTimeout(function(){
      products.subscribe(
        function onNext(result) {console.log('Result 2: ', result.response)},
        function onError(error) {console.log('ERROR', error)}
      )
    }, 5000)
  • 相关阅读:
    html页面自动运行php文件
    在数据库原有字段后增加新内容
    mysql判断字段不等于空
    php中的日期加减
    js验证只能输入中文
    session_start()关于Cannot send session cache limiter headers already sent错误解决方法
    php记录前一页面url
    打印功能
    js验证email
    用php获取本周,上周,本月,上月,本季度日期
  • 原文地址:https://www.cnblogs.com/Answer1215/p/5778453.html
Copyright © 2011-2022 走看看