index.js:
var koa = require('koa')
, Primus = require('primus.io')
, http = require('http')
, app = koa()
, server = http.createServer(app);
var primus = new Primus(server, { transformer: 'websockets', parser: 'JSON' });
primus.on('connection', function (spark) {
spark.send('news', { hello: 'world' });
spark.on('my other event', function (data) {
console.log(data);
});
});
app.get('/', function (req, res) {
res.sendfile(__dirname + '/index.html');
});
server.listen(8080);
console.log('8080');
跑:node --harmony index
和错误:throw TypeError('listener must be a function');