cycle-server(rxjs-run).js

const Subject = require('rxjs').Subject
const run = require('@cycle/rxjs-run').run
const http = require('http')

const makeServerDriver = port => {
  const requests$ = new Subject()

  http.createServer((req, res) => requests$.next({ req, res }))
    .listen(port, _ => console.log(`listening on ${port}`))

  return sink$ => (
    sink$.zip(requests$, (sink, { req, res }) => ({ sink, res }))
      .subscribe(({ sink, res }) => res.end(sink)),
    requests$.map(({ req, res }) => req))
}

const main = ({ server }) => ({
  server: server.map(req => `request for ${req.url}`)
})

run(main, { server: makeServerDriver(3000) })