я новичок в Rx и, к сожалению, очень плохо знаком с js и потоками в js. Я использую этоhttps://github.com/trygve-lie/twitter-stream-api подключаться к твитерам потокового API и получать объекты JSON с твитами. Пока у меня есть этот код

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);
});

Я успешно пишу твиты на консоль, но на самом деле я пытаюсь научиться работать с потоками и, в частности, с RxJS. Я перепробовал все возможные способы создания наблюдаемого. Rx.Observable. создать / из и т.д ...

Я также попробовал Twitter.resume (), так как он, по-видимому, приостановлен по умолчанию, чтобы возобновить поток и наблюдать за этим. Я получаю только такие ошибки, как не могу. Подписка не является функцией. Из того, что у меня есть выше, как я могу использовать Rx.Observable, чтобы начать фильтровать и воспроизводить данные?

Спасибо!