Object
A convenience method for creating and connecting.
# File lib/em-twitter/client.rb, line 28 def self.connect(options = {}) new(options).tap do |client| client.connect end end
# File lib/em-twitter/client.rb, line 34 def initialize(options = {}) @options = DEFAULT_CONNECTION_OPTIONS.merge(options) validate_client @host = @options[:host] @port = @options[:port] if @options[:proxy] && @options[:proxy][:uri] proxy_uri = URI.parse(@options[:proxy][:uri]) @host = proxy_uri.host @port = proxy_uri.port end @connection = nil end
# File lib/em-twitter/client.rb, line 50 def connect @connection = EM.connect(@host, @port, Connection, self, @host, @port) end
# File lib/em-twitter/client.rb, line 54 def each(&block) @each_item_callback = block end
Delegate to EM::Twitter::Connection
# File lib/em-twitter/client.rb, line 112 def method_missing(method, *args, &block) return super unless @connection.respond_to?(method) @connection.send(method, *args, &block) end
# File lib/em-twitter/client.rb, line 103 def on_close(&block) @close_callback = block end
# File lib/em-twitter/client.rb, line 86 def on_enhance_your_calm(&block) @enhance_your_calm_callback = block end
# File lib/em-twitter/client.rb, line 58 def on_error(&block) @error_callback = block end
# File lib/em-twitter/client.rb, line 66 def on_forbidden(&block) @forbidden_callback = block end
# File lib/em-twitter/client.rb, line 99 def on_max_reconnects(&block) @max_reconnects_callback = block end
# File lib/em-twitter/client.rb, line 107 def on_no_data_received(&block) @no_data_callback = block end
# File lib/em-twitter/client.rb, line 74 def on_not_acceptable(&block) @not_acceptable_callback = block end
# File lib/em-twitter/client.rb, line 70 def on_not_found(&block) @not_found_callback = block end
# File lib/em-twitter/client.rb, line 82 def on_range_unacceptable(&block) @range_unacceptable_callback = block end
# File lib/em-twitter/client.rb, line 95 def on_reconnect(&block) @reconnect_callback = block end
Generated with the Darkfish Rdoc Generator 2.