Contents

require "streamit/async_queue"
require "mongo_mapper"

# We are required to choose a database name
MongoMapper.database = "streamit-#{Rails.env}"

module Streamit
  autoload :DSL,   'streamit/dsl'
  autoload :Store, 'streamit/store'
  
  module ORM
    autoload :MongoMapper, 'streamit/orm/mongo_mapper'
  end
  
  extend AsyncQueue
  
  def self.setup
    yield self
  end
  
  # Set which store to use.
  #
  #   Streamit.set_store { Stream }
  #
  def self.set_store(&block)
    singleton_class.send :define_method, :store, &block
  end

  # Place holder for the store.
  def self.store; end
  
  def self.save_stream!(args)
    enqueue(args)
  end
  
  def self.process(args)
    store.save_stream!(args)
  end
  
end

require 'streamit/engine'

require 'active_support/i18n'
I18n.load_path << File.expand_path('../streamit/locales/en.yml', __FILE__)

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
streamit-0.0.8	lib/streamit.rb