rxjsautocomplete.js

rxjsautocomplete.js

window.application = {};
window.application.search = (function(){


    function searchwikipedia(term) {
        return $.ajaxAsObservable({
            url: 'http://en.wikipedia.org/w/api.php',
            data: { action: 'opensearch',
                search: term,
                format: 'json' },
            dataType: 'jsonp'
        });
    }

    var searchbox = $('#search');
    var selector = $('#results');

    var keypresses = searchbox.keyupAsObservable()
        .map( function(ev){
            return $(ev.target).val();
        });

    keypresses.filter(
        function(v){
            return v.length < 2;
        })
        .forEach(
            function() {
                selector.text('');
            },
            function(){
                selector.text('');
            },
            function(){
                selector.text('');
            }
        );

    var searchableKeypresses = keypresses.filter(
        function(v){
            return v.length > 1;
        })
        .throttle(100)
        .distinctUntilChanged();

    var requests = searchableKeypresses.flatMapLatest(function(term){
        return searchwikipedia(term);
    });


    var subscriber = requests.forEach(
        function(data){
            selector.text('');
            var elements = data.data['1'];
            $.each(elements, function (_, text) {
                $('<li>' + text + '</li>').appendTo(selector);
            });
        },
        function(error){
            selector.text('');
            $('<li>Error: ' + error + '</li>').appendTo('#results');
        },
        function(){

        }
    );
});