streams.js

var requestStream = refreshClickStream.startWith('startup click')
    .map(function() {
        return 'https://api.punkapi.com/v2/beers';
    });

var responseStream = requestStream
    .flatMap(function(requestUrl) {
        return Rx.Observable.fromPromise($.getJSON(requestUrl));
    });

function createSuggestionStream(closeClickStream) {
    return closeClickStream.startWith('startup click')
        .combineLatest(responseStream,
            function(click, listBeers) {
              // console.log(listBeers);
                return listBeers[Math.floor(Math.random()*listBeers.length)];
            }
        )
        .merge(
            refreshClickStream.map(function(){
                return null;
            })
        )
        .startWith(null);
}

var suggestion1Stream = createSuggestionStream(close1ClickStream);
var suggestion2Stream = createSuggestionStream(close2ClickStream);
var suggestion3Stream = createSuggestionStream(close3ClickStream);