1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
| | #\-E none
# can't use non-compatible middleware that doesn't pass "deferered?" calls
#
# used for testing deferred actions for Merb and possibly other frameworks
# ref: http://brainspl.at/articles/2008/04/18/deferred-requests-with-merb-ebb-and-thin
class DeferredApp < Struct.new(:app)
def deferred?(env)
env["PATH_INFO"] =~ %r{\A/deferred}
end
def call(env)
env["rack.multithread"] or raise RuntimeError, "rack.multithread not true"
body = "#{Thread.current.inspect}\n"
if env["PATH_INFO"] =~ %r{\A/deferred(\d+)}
delay = $1.to_i
File.open(ENV['fifo'], 'w') { |fp| fp.write "sleeping #{delay}s\n" }
body = "deferred sleep\n"
sleep(delay)
end
headers = {
"Content-Type" => "text/plain",
"Content-Length" => body.size.to_s,
}
[ 200, headers, [ body ] ]
end
end
run DeferredApp.new
|