This commit is contained in:
John Bintz 2012-09-15 12:28:35 -04:00
parent 1c2744a3aa
commit db61e54010
2 changed files with 3 additions and 1 deletions

View File

@ -19,6 +19,8 @@ module Rack
def _call(env) def _call(env)
result = @app.call(env) result = @app.call(env)
result[2].close if result[2].respond_to?(:close)
EM.next_tick { EM.next_tick {
env['async.callback'].call [ result[0], result[1], self ] env['async.callback'].call [ result[0], result[1], self ]

View File

@ -1,5 +1,5 @@
module Rack module Rack
class EMStream class EMStream
VERSION = "0.1.1" VERSION = "0.1.3"
end end
end end