From ea4a01df8b1fa29e2088816f4734bb0073eb9380 Mon Sep 17 00:00:00 2001 From: Eric Wong Date: Thu, 20 Jan 2011 22:15:12 +0000 Subject: remove support for Sunshowers The WebSocket protocol is still undergoing changes and unused. We won't waste time supporting it until it's finalized and doesn't break HTTP. --- lib/rainbows/const.rb | 6 ------ lib/rainbows/coolio_fiber_spawn.rb | 12 ++++++------ lib/rainbows/process_client.rb | 2 -- lib/rainbows/rev_fiber_spawn.rb | 8 ++++---- lib/rainbows/revactor/client.rb | 1 - 5 files changed, 10 insertions(+), 19 deletions(-) (limited to 'lib/rainbows') diff --git a/lib/rainbows/const.rb b/lib/rainbows/const.rb index 33df05d..559659c 100644 --- a/lib/rainbows/const.rb +++ b/lib/rainbows/const.rb @@ -14,12 +14,6 @@ module Rainbows::Const # "rainbows.autochunk" => false, }) - # client IO object that supports reading and writing directly - # without filtering it through the HTTP chunk parser. - # Maybe we can get this renamed to "rack.io" if it becomes part - # of the official spec, but for now it is "hack.io" - CLIENT_IO = "hack.io".freeze - RACK_INPUT = Unicorn::HttpRequest::RACK_INPUT REMOTE_ADDR = Unicorn::HttpRequest::REMOTE_ADDR end diff --git a/lib/rainbows/coolio_fiber_spawn.rb b/lib/rainbows/coolio_fiber_spawn.rb index 094e18e..52b3e63 100644 --- a/lib/rainbows/coolio_fiber_spawn.rb +++ b/lib/rainbows/coolio_fiber_spawn.rb @@ -2,12 +2,12 @@ require 'rainbows/fiber/coolio' # A combination of the Coolio and FiberSpawn models. This allows Ruby -# 1.9 Fiber-based concurrency for application processing while -# exposing a synchronous execution model and using scalable network -# concurrency provided by Cool.io. A "rack.input" is exposed as well -# being Sunshowers-compatible. Applications are strongly advised to -# wrap all slow IO objects (sockets, pipes) using the -# Rainbows::Fiber::IO or a Cool.io-compatible class whenever possible. +# 1.9 Fiber-based concurrency for application processing while exposing +# a synchronous execution model and using scalable network concurrency +# provided by Cool.io. A streaming "rack.input" is exposed. +# Applications are strongly advised to wrap all slow IO objects +# (sockets, pipes) using the Rainbows::Fiber::IO or a Cool.io-compatible +# class whenever possible. module Rainbows::CoolioFiberSpawn include Rainbows::Base diff --git a/lib/rainbows/process_client.rb b/lib/rainbows/process_client.rb index 2ddc368..bf6d20b 100644 --- a/lib/rainbows/process_client.rb +++ b/lib/rainbows/process_client.rb @@ -6,7 +6,6 @@ module Rainbows::ProcessClient NULL_IO = Unicorn::HttpRequest::NULL_IO RACK_INPUT = Unicorn::HttpRequest::RACK_INPUT - CLIENT_IO = "hack.io".freeze IC = Unicorn::HttpRequest.input_class def process_loop @@ -46,6 +45,5 @@ module Rainbows::ProcessClient def set_input(env, hp) env[RACK_INPUT] = 0 == hp.content_length ? NULL_IO : IC.new(self, hp) - env[CLIENT_IO] = self end end diff --git a/lib/rainbows/rev_fiber_spawn.rb b/lib/rainbows/rev_fiber_spawn.rb index 52ba2cd..434d72c 100644 --- a/lib/rainbows/rev_fiber_spawn.rb +++ b/lib/rainbows/rev_fiber_spawn.rb @@ -6,8 +6,8 @@ Rainbows.const_set(:RevFiberSpawn, Rainbows::CoolioFiberSpawn) # A combination of the Rev and FiberSpawn models. This allows Ruby # 1.9 Fiber-based concurrency for application processing while # exposing a synchronous execution model and using scalable network -# concurrency provided by Rev. A "rack.input" is exposed as well -# being Sunshowers-compatible. Applications are strongly advised to -# wrap all slow IO objects (sockets, pipes) using the -# Rainbows::Fiber::IO or a Rev-compatible class whenever possible. +# concurrency provided by Rev. A streaming "rack.input" is exposed. +# Applications are strongly advised to wrap all slow IO objects +# (sockets, pipes) using the Rainbows::Fiber::IO or a Rev-compatible +# class whenever possible. module Rainbows::RevFiberSpawn; end diff --git a/lib/rainbows/revactor/client.rb b/lib/rainbows/revactor/client.rb index fc095b5..1aabf93 100644 --- a/lib/rainbows/revactor/client.rb +++ b/lib/rainbows/revactor/client.rb @@ -39,7 +39,6 @@ class Rainbows::Revactor::Client def set_input(env, hp) env[RACK_INPUT] = 0 == hp.content_length ? NULL_IO : IC.new(@ts = TeeSocket.new(@client), hp) - env[CLIENT_IO] = @client end def close -- cgit v1.2.3-24-ge0c7