Minimal rxjs autocomplete impl

rxjs-autocomplete.js

// Based on https://github.com/Reactive-Extensions/RxJS/tree/master/examples/autocomplete

var Rx = require("rx-dom");
var querystring = require("querystring");
var jsonp = require("jsonp");

function searchWikipedia(term) {
  return new Promise((resolve, reject) => {

    var params = querystring.stringify({
      search: term,
      action: 'opensearch',
      format: 'json'
    });

    jsonp(`http://en.wikipedia.org/w/api.php?${params}`, (err, result)=> {
      err ? reject(err) : resolve(result);
    });
  });
}

function setup() {
  var textInput = document.getElementById('textInput');
  var results = document.getElementById('results');

  Rx.DOM.keyup(textInput)
    .map(e => e.target.value)
    .filter(text => text.length > 2)
    .throttle(150)
    .distinctUntilChanged()
    .flatMapLatest(searchWikipedia)
    .map(data => data[1])
    .subscribe(writeResults, handleError);

  function writeResults(res) {
    results.innerHTML = (res.length ? res : ['No hits']).map(value => `<li>${value}</li>`).join('');
  }

  function handleError(error) {
    results.innerHTML = `<li>${error}</li>`;
  }
}

document.addEventListener('DOMContentLoaded', setup);