Class: Rubko

Inherits:
Object
  • Object
show all
Defined in:
lib/rubko.rb,
lib/rubko/base.rb

Defined Under Namespace

Modules: Base Classes: App, Asset, Controller, Model, Plugin, Socket, Storage

Constant Summary collapse

VERSION = 
'0.2'

Instance Method Summary collapse

Constructor Details

#initialize(shared = {}) ⇒ Rubko

Returns a new instance of Rubko.



6
7
8
9
10
11
12
13
 
# File 'lib/rubko.rb', line 6

def initialize(shared = {})
  @shared = shared

  Dir['./includes/**/*.rb'].each { |file|
    require file
  }
  puts 'Server started successfully.'
end

Instance Method Details

#call(env) ⇒ Object 



27
28
29
30
31
 
# File 'lib/rubko.rb', line 27

def call(env)
  abort if env['rack.multithread']
  app = Rubko::App.new env, @shared
  app.init env['REQUEST_URI'].encode 'utf-8'
end

#threaded ⇒ Object

do not USE !



16
17
18
19
20
21
22
23
24
25
 
# File 'lib/rubko.rb', line 16

def threaded
  EM.threadpool_size = 50
  -> env {
    EM.defer(
      -> { call env },
      -> r { env['async.callback'].call r }
    )
    throw :async
  }
end