cdimascio/1_index.html

## 1_index.html
<!DOCTYPE html>
<html>
<head>
<script src="https://code.jquery.com/jquery-2.1.4.js"></script>
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/4.0.6/rx.all.js"></script>
  <meta charset="utf-8">
  <title>Test</title>
</head>
<body>
<input id="textbox">
<div id="results"></div>
</body>
</html>

## 2_autocomplete.js
var Observable = Rx.Observable;

var textbox = $('#textbox');
var results = $('#results');

var keyPresses = Observable.fromEvent(textbox, 'keyup');
var searchResultSet = keyPresses.
  throttle(20).
  map(key => textbox.val()).
  distinctUntilChanged().
  map(search => getWikipediaSearchResults(search).retry(3)).
  switchLatest();

searchResultSet.forEach(
  r => {
    results.empty();
    results.append(r.join('<br>'));
  },
  err => {
    results.empty();
    results.append(err);
  });

// Convert getJSON request to Wikipedia into an Observable
function getWikipediaSearchResults(term) {
  return Observable.create(function forEach(observer) {
    var canceled = false;
    var url = 'https://en.wikipedia.org/w/api.php?action=opensearch&format=json&search=' +
        encodeURIComponent(term) + '&callback=?';
    if (!canceled) {
      $.getJSON(url).done(data => {
        observer.onNext(data[1]);
        observer.onCompleted();
      });
    }
    return function dispose() {
      canceled = true;
    }
  });
}
	<!DOCTYPE html>
	<html>
	<head>
	<script src="https://code.jquery.com/jquery-2.1.4.js"></script>
	<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/4.0.6/rx.all.js"></script>
	<meta charset="utf-8">
	<title>Test</title>
	</head>
	<body>
	<input id="textbox">
	<div id="results"></div>
	</body>
	</html>
	var Observable = Rx.Observable;

	var textbox = $('#textbox');
	var results = $('#results');

	var keyPresses = Observable.fromEvent(textbox, 'keyup');
	var searchResultSet = keyPresses.
	throttle(20).
	map(key => textbox.val()).
	distinctUntilChanged().
	map(search => getWikipediaSearchResults(search).retry(3)).
	switchLatest();

	searchResultSet.forEach(
	r => {
	results.empty();
	results.append(r.join('<br>'));
	},
	err => {
	results.empty();
	results.append(err);
	});

	// Convert getJSON request to Wikipedia into an Observable
	function getWikipediaSearchResults(term) {
	return Observable.create(function forEach(observer) {
	var canceled = false;
	var url = 'https://en.wikipedia.org/w/api.php?action=opensearch&format=json&search=' +
	encodeURIComponent(term) + '&callback=?';
	if (!canceled) {
	$.getJSON(url).done(data => {
	observer.onNext(data[1]);
	observer.onCompleted();
	});
	}
	return function dispose() {
	canceled = true;
	}
	});
	}