Contents

module EventMachine
  class Beanstalk
    class Defer < EM::DefaultDeferrable
      def initialize(default_error_callback, &block)
        @error = default_error_callback
        callback(&block) if block
        errback{|message| @error.call(message)}
      end
      
      def on_error(&block)
        @error = block
        self
      end
      
      def on_success(&block)
        callback(&block)
        self
      end
      
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
em-beanstalk-0.0.10	lib/em-beanstalk/defer.rb
em-beanstalk-0.0.9	lib/em-beanstalk/defer.rb
em-beanstalk-0.0.8	lib/em-beanstalk/defer.rb
em-beanstalk-0.0.7	lib/em-beanstalk/defer.rb
em-beanstalk-0.0.6	lib/em-beanstalk/defer.rb