const Koa = require('koa')
const koaRx = require('koa-rx').default
 
const app = new Koa()
app.use(koaRx())
app.use(ctx => Observable.of(418).do(n => ctx.status = n))