]> jfr.im git - erebus.git/blobdiff - modules/contrib/sseclient.py
implement handleState and getText
[erebus.git] / modules / contrib / sseclient.py
index 1cfcd171fcf42446fde6aa6c5af8437dc41418d7..3d535726352de607bc330a55fda7eabf7dd73585 100644 (file)
@@ -54,7 +54,7 @@ class SSEClient(object):
         # Use session if set.  Otherwise fall back to requests module.
         requester = self.session or requests
         self.resp = requester.get(self.url, stream=True, **self.requests_kwargs)
-        self.resp_iterator = self.iter_content()
+        self.resp_iterator = self.resp.iter_content(chunk_size=None)
         encoding = self.resp.encoding or self.resp.apparent_encoding
         self.decoder = codecs.getincrementaldecoder(encoding)(errors='replace')