Module: Streamit

Extended by:
AsyncQueue
Defined in:
lib/streamit.rb,
lib/streamit/dsl.rb,
lib/streamit/store.rb,
lib/streamit/engine.rb,
lib/streamit/version.rb,
lib/streamit/async_queue.rb,
lib/streamit/orm/mongo_mapper.rb,
lib/generators/streamit/streamit_generator.rb

Defined Under Namespace

Modules: AsyncQueue, DSL, Generators, ORM, Store Classes: Engine, StreamsController

Constant Summary collapse

VERSION = 
'0.0.8'.freeze

Class Method Summary collapse

Methods included from AsyncQueue

enqueue, finish!, process, queue, thread

Class Method Details

.process(args) ⇒ Object 



36
37
38
 
# File 'lib/streamit.rb', line 36

def self.process(args)
  store.save_stream!(args)
end

.save_stream!(args) ⇒ Object 



32
33
34
 
# File 'lib/streamit.rb', line 32

def self.save_stream!(args)
  enqueue(args)
end

.set_store(&block) ⇒ Object

Set which store to use.

Streamit.set_store { Stream }



25
26
27
 
# File 'lib/streamit.rb', line 25

def self.set_store(&block)
  singleton_class.send :define_method, :store, &block
end

.setup {|_self| ... } ⇒ Object

Yields:

  • (_self)

Yield Parameters:

  • _self (Streamit) —

    the object that the method was called on



17
18
19
 
# File 'lib/streamit.rb', line 17

def self.setup
  yield self
end

.store ⇒ Object

Place holder for the store.



30
 
# File 'lib/streamit.rb', line 30

def self.store; end