text: const repl = require('repl').repl
  
  const { play } = repl.context
  
  const Rx = require('node-keyboard-rx')()
  
  const mongo = require('node-keyboard-mongo')
  
  module.exports = () => {
      const { query, log, compose } = mongo
  
      const cursor = query({
          uri: 'mongodb://localhost:26000',
          db: 'example',
          collection: 'users',
          findQuery: {
              name: {
                  $exists: 1
              }
          }
      })
  
      // tail is Rx Observable of oplog events
      cursor
          .concatMap(x => Rx.Observable.of(x).delay(500))
          .do(log) // log out received data
          .flatMap(compose) // transform data into music
          .subscribe(play, console.error) // play music
  }
  