你可以用它来做publish:
Meteor._sleepForMs(5000); // sleeps for 5 seconds
Run Code Online (Sandbox Code Playgroud)
我想我参加派对有点晚了,但这里有一个更好的解决方案:
这个问题基本上有两个部分。一个是如何延迟 Meteor WebSocket ( SockJS ) 写入,一个是如何延迟 HTTP 流量 ( connect )。您需要将以下两个片段添加到您的服务器端代码中,以延迟从 Meteor 服务器发送的所有流量。
困难的部分是覆盖 WebSocketwrite以延迟它setTimeout:
(function () {
// Set the delay you want
var timeout = 3000
// stream_server abstracts sockJS the DDP-Server talks to it.
var streamServer = Meteor.server.stream_server
// The connect event listener
var standardConnect = streamServer.server._events.connection
// Overwrite the default event-handler
streamServer.server._events.connection = function (socket) {
// Overwrite the writes to the socket
var write = socket.write
socket.write = function () {
var self = this
var args = arguments
// Add a delay
setTimeout(function () {
// Call the normal write methods with the arguments passed to this call
write.apply(self, args)
}, timeout)
}
// Call the normal handler after overwritting the socket.write function
standardConnect.apply(this, arguments)
}
})()
Run Code Online (Sandbox Code Playgroud)
通过连接,它非常简单:
// Add a simple connect handler, wich calls the next handler after a delay
WebApp.rawConnectHandlers.use(function (req, res, next) {
return setTimeout(next, timeout)
})
Run Code Online (Sandbox Code Playgroud)
不确定所有调用,但您可以使用 Futures 在服务器上添加延迟,这样您就可以看到延迟补偿的实际效果。
例如,在流星方法中,您可以
Meteor.methods({
post: function(post) {
post.title = post.title + (this.isSimulation ? '(client)' : '(server)');
// wait for 5 seconds
if (! this.isSimulation) {
var Future = Npm.require('fibers/future');
var future = new Future();
Meteor.setTimeout(function() {
future.ret();
}, 5 * 1000); // 5 seconds
future.wait();
}
var postId = Posts.insert(post);
return postId;
}
});
Run Code Online (Sandbox Code Playgroud)
这将显示插入的帖子末尾附加有 (client),然后 5 秒后将从服务器获取更新,帖子标题将以 (server) 结尾
| 归档时间: |
|
| 查看次数: |
1360 次 |
| 最近记录: |