reactive programming with the Twitter streaming API

rx-twit.js

const conf = require('./conf').twit;
const Twit = require('twit')
const Rx = require('rxjs/Rx')

const subject = new Rx.Subject()
  .map(({
    text,
    user: {
      screen_name
    }
  }) => `@${screen_name}: ${text}`)

subject.subscribe({
  next: v => console.log('next: ' + v),
  error: v => console.log('error: ' + v),
  complete: () => console.log('complete'),
})

new Twit(conf)
  .stream('user')
  .on('tweet', e => subject.next(e))