Don't wrap wsgi.input with GreenBody if it is already wrapped #releas…

…e-note
quantmind · May 17, 2016 · d66ddb8 · d66ddb8
1 parent 59d1f63
commit d66ddb8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/pulsar/__init__.py b/pulsar/__init__.py
@@ -5,7 +5,7 @@
 from .utils.version import get_version
 
 
-VERSION = (1, 3, 1, 'alpha', 0)
+VERSION = (1, 3, 1, 'final', 0)
 
 __version__ = version = get_version(VERSION)
 

diff --git a/pulsar/apps/greenio/wsgi.py b/pulsar/apps/greenio/wsgi.py
@@ -21,8 +21,9 @@ def __call__(self, environ, start_response):
             return self.pool.submit(self._call, environ, start_response)
 
     def _call(self, environ, start_response):
-        if environ['wsgi.input']:
-            environ['wsgi.input'] = GreenStream(environ['wsgi.input'])
+        wsgi_input = environ['wsgi.input']
+        if wsgi_input and not isinstance(wsgi_input, GreenStream):
+            environ['wsgi.input'] = GreenStream(wsgi_input)
         response = None
         try:
             for middleware in self.middleware: