X-Git-Url: https://jfr.im/git/erebus.git/blobdiff_plain/d2646ec9f434a07010525f1af895c61a4921922e..a21d28c0895024cf1099a6df527dcddf981ee7d6:/modules/contrib/sseclient.py diff --git a/modules/contrib/sseclient.py b/modules/contrib/sseclient.py index 1cfcd17..3d53572 100644 --- a/modules/contrib/sseclient.py +++ b/modules/contrib/sseclient.py @@ -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')