【发布时间】:2014-10-03 03:59:36
【问题描述】:
有没有办法在保持时间控制的同时拆分和循环每个客户端?我需要发出所有推文,但每条推文之间都有固定的时间。到目前为止,这是引发异常的代码:
var socketList = new Array();
io.on('connection',function(socket){
socketList.push(socket);
});
setInterval(function() {
socketList.forEach('tweet', function(tweet) {
io.sockets.emit('info', {tweet: tweet});
});
}, 2000);
此代码有效,但流式传输推文太快:
io.on('connection', function (socket) {
stream.on('tweet', function(tweet) {
socket.emit('info', {tweet: tweet});
});
});
编辑此代码不会给出任何错误,但不会流式传输任何推文:
var io = require('socket.io').listen(server);
var stream = T.stream('statuses/filter', { track: 'lol' })
var socketList = new Array();
io.on('connection',function(socket){
socketList.push(socket);
});
function EmitTweets() {
stream.socketList.forEach('tweet', function(tweet) {
io.sockets.emit('info', {tweet: tweet});
});
setTimeout(EmitTweets, 1000);
}
不知道在哪里可以调用“流”
【问题讨论】:
-
您找到问题和解决方案了吗?
标签: javascript node.js twitter websocket socket.io