Sha256: 9e79701609b6e7009e0f63595271ab525723fbe88ffc7c09e5c4fc4cd7c20536
Contents?: true
Size: 1.82 KB
Versions: 4
Compression:
Stored size: 1.82 KB
Contents
module Twitter class JSONStream protected def reconnect_after timeout @reconnect_callback.call(timeout, @reconnect_retries) if @reconnect_callback if timeout == 0 reconnect @options[:host], @options[:port] start_tls if @options[:ssl] else EventMachine.add_timer(timeout) do reconnect @options[:host], @options[:port] start_tls if @options[:ssl] end end end end end module TwitterOAuth class Client private def consumer @consumer ||= OAuth::Consumer.new( @consumer_key, @consumer_secret, { :site => 'https://api.twitter.com', :proxy => @proxy } ) end end end class String def c(*codes) return self if Earthquake.config[:lolize] codes = codes.flatten.map { |code| case code when String, Symbol Earthquake.config[:color][code.to_sym] rescue nil else code end }.compact.unshift(0) "\e[#{codes.join(';')}m#{self}\e[0m" end def coloring(pattern, color = nil, &block) return self if Earthquake.config[:lolize] self.gsub(pattern) do |i| applied_colors = $`.scan(/\e\[[\d;]+m/) c = color || block.call(i) "#{i.c(c)}#{applied_colors.join}" end end t = { ?& => "&", ?< => "<", ?> => ">", ?' => "'", ?" => """, } define_method(:u) do gsub(/(#{Regexp.union(t.values)})/o, t.invert) end define_method(:e) do gsub(/[#{t.keys.join}]/o, t) end def indent(count, char = ' ') (char * count) + gsub(/(\n+)/) { |m| m + (char * count) } end def trim_indent lines = self.split("\n") unindent = self.split("\n").select { |s| s !~ /^\s$/ }.map { |s| s.index(/[^\s]/) || 0 }.min lines.map { |s| s.gsub(/^#{' ' * unindent}/, '') }.join("\n") end end
Version data entries
4 entries across 4 versions & 1 rubygems
Version | Path |
---|---|
earthquake-0.8.5 | lib/earthquake/ext.rb |
earthquake-0.8.4 | lib/earthquake/ext.rb |
earthquake-0.8.3 | lib/earthquake/ext.rb |
earthquake-0.8.2 | lib/earthquake/ext.rb |