diff options
author | Eric Wong <normalperson@yhbt.net> | 2010-07-10 08:04:48 +0000 |
---|---|---|
committer | Eric Wong <normalperson@yhbt.net> | 2010-07-10 08:04:48 +0000 |
commit | d3b97d1114e2d23a9231fe889cd5bf6927d451ba (patch) | |
tree | 6c4d7a033dad1edc91b72a9e7fa36203c60c8116 /lib/rainbows/event_machine.rb | |
parent | 9838b614621bbbff27a91166406d833be85adbbd (diff) | |
download | rainbows-d3b97d1114e2d23a9231fe889cd5bf6927d451ba.tar.gz |
Since we suck at building websites, we just rely on RDoc as a website builder. And since Rainbows! is an application server (and not a programming library), our internal API should be of little interest to end users. Anybody interested in Rainbows! (or any other project) internals should be reading the source.
Diffstat (limited to 'lib/rainbows/event_machine.rb')
-rw-r--r-- | lib/rainbows/event_machine.rb | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/lib/rainbows/event_machine.rb b/lib/rainbows/event_machine.rb index bbb38fa..173340e 100644 --- a/lib/rainbows/event_machine.rb +++ b/lib/rainbows/event_machine.rb @@ -48,7 +48,7 @@ module Rainbows include Base - class Client < EM::Connection + class Client < EM::Connection # :nodoc: all include Rainbows::EvCore include Rainbows::Response G = Rainbows::G @@ -149,7 +149,7 @@ module Rainbows end end - module ResponsePipe + module ResponsePipe # :nodoc: all def initialize(client) @client = client end @@ -160,7 +160,7 @@ module Rainbows end end - module ResponseChunkPipe + module ResponseChunkPipe # :nodoc: all include ResponsePipe def unbind @@ -187,7 +187,7 @@ module Rainbows end end - module Server + module Server # :nodoc: all def close detach @@ -205,7 +205,7 @@ module Rainbows # Middleware that will run the app dispatch in a separate thread. # This middleware is automatically loaded by Rainbows! when using # EventMachine and if the app responds to the +deferred?+ method. - class TryDefer < Struct.new(:app) + class TryDefer < Struct.new(:app) # :nodoc: all def initialize(app) # the entire app becomes multithreaded, even the root (non-deferred) @@ -226,7 +226,7 @@ module Rainbows end end - def init_worker_process(worker) + def init_worker_process(worker) # :nodoc: Rainbows::Response.setup(Rainbows::EventMachine::Client) super end @@ -234,7 +234,7 @@ module Rainbows # runs inside each forked worker, this sits around and waits # for connections and doesn't die until the parent dies (or is # given a INT, QUIT, or TERM signal) - def worker_loop(worker) + def worker_loop(worker) # :nodoc: init_worker_process(worker) G.server.app.respond_to?(:deferred?) and G.server.app = TryDefer[G.server.app] |