x-streams

https://github.com/sferik/x-ruby

Streaming for the X gem: the sample and filtered streams, reconnected as X recommends, and the rules of the filtered stream.