Contents

module Monkeyshines
  module RequestStream

    #
    # RequestStream::Base
    #
    #
    class Base
      attr_accessor :options
      Base::DEFAULT_OPTIONS = {}
      def initialize _options={}
        self.options = Base::DEFAULT_OPTIONS.deep_merge(_options)
        Log.debug "New #{self.class} as #{options.inspect}"
      end

      def each *args, &block
        self.request_store.each(*args) do |*raw_req_args|
          req = request_from_raw(*raw_req_args)
          yield req
        end
      end

      def put *args
        request_store.put *args
      end

      def skip! *args
        request_store.skip! *args
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
monkeyshines-0.2.3	lib/monkeyshines/request_stream/base.rb
monkeyshines-0.2.2	lib/monkeyshines/request_stream/base.rb
monkeyshines-0.2.1	lib/monkeyshines/request_stream/base.rb
monkeyshines-0.2.0	lib/monkeyshines/request_stream/base.rb
monkeyshines-0.0.2	lib/monkeyshines/request_stream/base.rb