model.js

function model(refreshClickStream$, close1ClickStream$, close2ClickStream$, close3ClickStream$) {
  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));
    });

  var suggestion1Stream = createSuggestionStream(refreshClickStream$, responseStream, close1ClickStream$);
  var suggestion2Stream = createSuggestionStream(refreshClickStream$, responseStream, close2ClickStream$);
  var suggestion3Stream = createSuggestionStream(refreshClickStream$, responseStream, close3ClickStream$);

  suggestion1Stream.subscribe(function(suggestedBeer) {
      renderSuggestion(suggestedBeer, '.suggestion1');
  });