var url = '/api/messages/stream-updates' +
      '?access_token=' + LoopBackAuth.accessTokenId;

    var src = new EventSource(url);
    var changes = createChangeStream(src);
    var set;

    Message.find({
      filter: {
        where: {
          userId: LoopBackAuth.currentUserId
        },
        order: 'created DESC',
        limit: 5
      }
    }).$promise.then(function(results) {
      set = new LiveSet(results, changes);
      vm.messages = set.toLiveArray();
    });