gazouillis
Gazouillis aims to be a fast and reliable twitter stream client.
Status
Very early stage. Not ready for production.
Usage
Connection to twitter's userstream:
require 'gazouillis'
class Timeline < Gazouillis::UserStream
def on_message(message)
# Do something with streamed message
#
# Parse message, and outputs.
#
p MultiJson.decode message
end
end
options = {
oauth: {
consumer_key: "consumer_key",
consumer_secret: "consumer_secret",
token: "token",
token_secret: "token_secret"
}
}
Timeline.new(options).openOr be barbone, and use the internal class.
require 'gazouillis'
class Tweets < Gazouillis::Stream
def on_message(message)
# Do something with streamed message
#
# Parse message, and outputs.
#
p MultiJson.decode message
end
end
options = {
oauth: {
consumer_key: "consumer_key",
consumer_secret: "consumer_secret",
token: "token",
token_secret: "token_secret"
}
}
Tweets.new('/1/statuses/sample.json', options).async.openGazouillis relies on Celluloid::IO.
Hence the async capability.
Roadmap
0.2.0
- UserStream, FilterStream and SampleStream
0.3.0
- Reconnector object.
Example
Copyright
MIT. See LICENSE for further details.