从Meteor.method中的回调中返回值

Question

我正在遇到Meteor不理解的事情.我有这个方法,它接受一个查询,发送到亚马逊,然后在该函数的回调中,我尝试返回结果.

Meteor.methods({
    'search': function(query) {
        var bookInfo;
        if (Meteor.isServer) {
            amazon.execute('ItemSearch', {
                'SearchIndex': 'Books',
                'Keywords': query,
                'ResponseGroup': 'ItemAttributes'
            }, function(results) {
                bookInfo = results;
                console.log(bookInfo);
                return bookInfo;
            });
        }
    }
});

但是当我在浏览器中将以下内容放入控制台(chrome)时:

Meteor.call('search', 'harry potter', function(error, response) {
    console.log('response:', response);
});

我明白了:

undefined
response: undefined          VM13464:3

我想我明白第一个undefined来自于在客户端上没有返回任何内容的方法,但回调似乎根本不起作用.

amazon.execute(...)肯定会返回一些东西,因为返回上方的console.log会记录我正在寻找的信息.

任何想法出了什么问题以及如何解决它？

Answer 1

您需要使用Future来实现您的目标.

自Meteor 0.6以来如何使用未来？

Meteor.startup(function () {
 Future = Npm.require('fibers/future');

 // use Future here
}

你的方法用Future重写:

Meteor.methods({
 'search': function(query) {

    var future = new Future();

    amazon.execute('ItemSearch', {
            'SearchIndex': 'Books',
            'Keywords': query,
            'ResponseGroup': 'ItemAttributes'
    }, function(results) {
       console.log(results);

       future["return"](results)

    });

    return future.wait();
 }
});

现在它应该工作.

Meteor.call('search', 'harry potter', function(error, response) {
   if(error){
    console.log('ERROR :', error);
   }else{
    console.log('response:', response);
   }

});

如果您想了解有关Future库的更多信息,我建议您观看截屏视频

2017年12月26日更新

我只是想更新这个答案,因为你可以使用promise实现同样的事情,因此,摆脱"纤维"依赖:)

一个例子胜过千言万语

import scrap from 'scrap';

Meteor.methods({
    'hof.add'(el) {
        check(el, {
            _link: String
        });

        const promise = getHofInfo(el._link)
            .then((inserter) => {
                inserter.owner = Meteor.userId();
                Hof.insert(inserter);
                return true;
            })
            .catch((e) => {
                throw new Meteor.Error('500', e.message);
            });
        return promise.await();
    }
});


function getHofInfo(_link) {
    return new Promise((resolve, reject) => {
        scrap(_link, function (err, $) {
            if (err) {
                reject(err);
            } else {
                const attakers = $('#report-attackers').find('li').text();
                const defender = $('#report-defenders').find('li').text();
                const _name = attakers + ' vs ' + defender;
                const _date = new Date();
                resolve({ _name, _date, _link });
            }
        });
    });
}