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

    <!DOCTYPE html>
    <html>
    <head>
    <script src="https://code.jquery.com/jquery-1.7.2.js"></script>
    <script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/4.0.8/rx.all.js"></script>
      <meta charset="utf-8">
      <title>JS Bin</title>
    </head>
    <body>
    <div class="container">
        <div class="header">
             <h3>Who to follow</h3><a href="#" class="refresh">Refresh</a>
        </div>
        <ul class="suggestions">
            <li class="suggestion1">
                <img />
                <a href="#" target="_blank" class="username">this will not be displayed</a>
                <a href="#" class="close close1">x</a>
            </li>
            <li class="suggestion2">
                <img />
                <a href="#" target="_blank" class="username">neither this</a>
                <a href="#" class="close close2">x</a>
            </li>
            <li class="suggestion3">
                <img />
                <a href="#" target="_blank" class="username">nor this</a>
                <a href="#" class="close close3">x</a>
            </li>
        </ul>
    </div>
    </body>
    </html>
    var refreshButton = document.querySelector('.refresh');
    
    
    
    
    
    var requestStream = Rx.Observable.just('https://api.github.com/users');
    
    var responseStream = requestStream
      .flatMap(requestUrl =>
        Rx.Observable.fromPromise(jQuery.getJSON(requestUrl))
      );
    
    function createSuggestionStream(responseStream) {
      return responseStream.map(listUser =>
        listUser[Math.floor(Math.random()*listUser.length)]
      );
    }
    
    var suggestion1Stream = createSuggestionStream(responseStream);
    var suggestion2Stream = createSuggestionStream(responseStream);
    var suggestion3Stream = createSuggestionStream(responseStream);
    
    function renderSuggestion(userData, selector) {
      var element = document.querySelector(selector);
      var usernameEl = element.querySelector('.username');
      usernameEl.href = userData.html_url;
      usernameEl.textContent = userData.login;
      var imgEl = element.querySelector('img');
      imgEl.src = userData.avatar_url;
    }
    
    suggestion1Stream.subscribe(user => {
      renderSuggestion(user, '.suggestion1');
    });
    
    suggestion2Stream.subscribe(user => {
      renderSuggestion(user, '.suggestion2');
    });
    
    suggestion3Stream.subscribe(user => {
      renderSuggestion(user, '.suggestion3');
    });
    body {
        font-family: sans-serif;
        padding: 10px;
    }
    h3 {
        font-weight: bold;
        display: inline-block;
      padding: 0;
      margin: 0;
    }
    .refresh {
        font-size: 80%;
        margin-left: 10px;
    }
    .header {
        background: #ECECEC;
        padding: 5px;
    }
    .suggestions {
        border: 2px solid #ECECEC;
    }
    li {
        padding: 5px;
    }
    li img {
        width: 40px;
        height: 40px;
        border-radius: 20px;
    }
    li .username, li .close {
        display: inline-block;
        position: relative;
        bottom: 15px;
        left: 5px;
    }
  • 相关阅读:
    HDFS升级域:Upgrade Domain
    HDFS升级域:Upgrade Domain
    HDFS数据快速拷贝方案:FastCopy
    HDFS数据快速拷贝方案:FastCopy
    Confluence 6 SQL Server 测试你的数据库连接
    Confluence 6 SQL Server 输入你的数据库细节
    Confluence 6 SQL Server 创建一个数据库和数据库用户
    Confluence 6 安装 SQL Server
    Confluence 6 Microsoft SQL Server 设置准备
    Confluence 6 Oracle 连接问题解决
  • 原文地址:https://www.cnblogs.com/Answer1215/p/5252592.html
Copyright © 2011-2022 走看看