var koa = require('koa');
var sse = require('koa-sse');
 
var app = koa();
 
app.use(sse());
app.use(function*(){
  this.sse(someStreamStream());
});
 
app.listen(3000);