使用 Bluebird.js 和 Twitter 流的 Promise 和流

我对 Promises 和 Node 非常陌生，并且对在流中使用 Promise 感到好奇。我可以承诺直播吗？ 使用 Bluebirdjs 和 Twit 模块，我有以下内容：

var Twit = require('twit')
var Promise = require("bluebird");

var T = new Twit({
 consumer_key:         process.env.CONSUMER_KEY,
 consumer_secret:      process.env.CONSUMER_SECRET,
 access_token:         process.env.ACCESS_TOKEN,
 access_token_secret:  process.env.ACCESS_TOKEN_SECRET
})

Promise.promisifyAll(Twit);
Promise.promisifyAll(T);

var sanFrancisco = [ '-122.75', '36.8', '-121.75', '37.8' ]

T.streamAsync('statuses/filter', { locations: sanFrancisco })
.then(function(connection){
 connection.onAsync('tweet')
  .then(function (tweet) {
   console.log(tweet)
  })
});

运行此代码不会记录推文，也不会引发错误。似乎没有发生任何连接，但 .then 承诺都不起作用。

原始片段，在尝试实现中找到的承诺之前推特文档 https://github.com/ttezel/twit

var sanFrancisco = [ '-122.75', '36.8', '-121.75', '37.8' ]

var stream = T.stream('statuses/filter', { locations: sanFrancisco })

stream.on('tweet', function (tweet) {
 console.log(tweet)
})

我很遗憾地说这是行不通的，因为 Promise 和 Stream 之间存在根本区别。您说您对两者都是新手，那么让我对两者进行简短的介绍。

Promise 可以被视为某些可能尚未到达的单个值的占位符。例如，一些假设函数getTweet()可以像这样工作：

getTweet()
    .then(function (tweet) {
        //Do something with your tweet!
        console.log(tweet);
    });

但这只会给你一条推文！要获得另一份，您必须致电getTweet()再次，用一个新的.then()在那后面。事实上，当使用 Promise 时，你可以保证.then()仅调用其包含函数一次！

流是连续的数据流。您不必手动请求一条推文，然后是另一条推文，然后是另一条推文。你打开水龙头，然后它就会一直流出来，直到它结束或你告诉它停止。

因此，总而言之，您不能承诺流，因为承诺适用于单个值，而流则适用于连续数据流。

我假设您问这个问题是因为您喜欢 Promise 接口并且希望对流使用类似的东西？根据您想要实现的目标，有不同的库可以使流处理变得更好。事件流 https://github.com/dominictarr/event-stream就是一个例子。让我知道你的计划，我也许可以给你一个例子。