Contents

require "remcached"

module Memcached
  class << self

    def connect(servers)
      Memcached.servers = servers

      f = Fiber.current
      @t = EM::PeriodicTimer.new(0.01) do
        if Memcached.usable?
          @t.cancel
          f.resume(self)
        end
      end

      Fiber.yield
    end

    %w[add get set delete].each do |type|
      class_eval %[
        def a#{type}(contents, &callback)
          df = EventMachine::DefaultDeferrable.new
          df.callback &callback

          cb = Proc.new { |res| df.succeed(res) }
          operation Request::#{type.capitalize}, contents, &cb

            df
        end

        def #{type}(contents, &callback)
          fiber = Fiber.current

          df = a#{type}(contents, &Proc.new { |res| fiber.resume(res) })
          df.callback &callback

          Fiber.yield
        end
      ]
    end

    %w[add get set delete].each do |type|
       class_eval %[
         def amulti_#{type}(contents, &callback)
           df = EventMachine::DefaultDeferrable.new
           df.callback &callback
    
           cb = Proc.new { |res| df.succeed(res) }
           multi_operation Request::#{type.capitalize}, contents, &cb
    
             df
         end
    
         def multi_#{type}(contents, &callback)
           fiber = Fiber.current
    
           df = amulti_#{type}(contents, &Proc.new { |res| fiber.resume(res) })
           df.callback &callback
    
           Fiber.yield
         end
       ]
     end

  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
em-synchrony-0.1.4	lib/em-synchrony/em-remcached.rb
em-synchrony-0.1.2	lib/em-synchrony/em-remcached.rb
em-synchrony-0.1.1	lib/em-synchrony/em-remcached.rb