因为如果您必须微调已发布的内容。
import { Mongo } from 'meteor/mongo'; import { Meteor } from 'meteor/meteor'; import { Random } from 'meteor/random'; if (Meteor.isClient) { // 仅在客户端上建立此集合。 // 名称是必需的(第一个参数),并且不会在服务器上保留。 const Messages = new Mongo.Collection('messages'); Meteor.startup(function () { Meteor.subscribe('messages'); Messages.find().observe({ added: function (message) { console.log('Received a new message at ' + message.timestamp); } }); }) } if (Meteor.isServer) { // 这将每5秒添加一条新消息。 Meteor.publish('messages', function () { const interval = Meteor.setInterval(() => { this.added('messages', Random.id(), { message: '5 seconds have passed', timestamp: new Date() }) }, 5000); this.added('messages', Random.id(), { message: 'First message', timestamp: new Date() }); this.onStop(() => Meteor.clearInterval(interval)); }); }