title: Subscribe to a stream with RxJS and twitter-stream-api module
body: <p>Ok, so I'm a complete beginner with Rx and unfortunately very new to js and streams in js as well. Im using this <a href="https://github.com/trygve-lie/twitter-stream-api" rel="nofollow noreferrer">https://github.com/trygve-lie/twitter-stream-api</a> to connect to twitters streaming api and receive json objects with tweets. So far I have this code </p>
  
  <pre><code>var Rx = require('rxjs/Rx');
  
  var TwitterStream = require('twitter-stream-api'),
      fs = require('fs');
  var filter = 'tweet';
  var keys = {
      consumer_key : "key",
      consumer_secret : "secret",
      token : "token",
      token_secret : "tokensecret"
  };
  
  var Twitter = new TwitterStream(keys);
  Twitter.stream('statuses/filter', {
      track: filter
  });
  
  Twitter.on('connection success', function (uri) {
      console.log('connection success', uri); 
  });
  Twitter.on('data', function (obj) {
      console.log(obj.text);
  });
  </code></pre>
  
  <p>I am successfully writing tweets to the console but what I am really trying to learn is working with streams and in particular RxJS. I have tried all the ways I can think of to create an observable. Rx.Observable. create/from etc... </p>
  
  <p>I have also tried Twitter.resume() as it is apparently paused by default to resume the stream and observe that. I only get errors such as cannot .subscribe is not a function. From what I have above, how can I use Rx.Observable to start filtering and playing around with the data?</p>
  
  <p>Thanks!</p>