diff options
-rw-r--r-- | proxy.py | 2 |
1 files changed, 1 insertions, 1 deletions
@@ -130,7 +130,7 @@ class MultipleProxyReader(object): speed = (self.endpoints_blocksize[endpoint] / time) self.endpoints_blocksize[endpoint] = int(speed * TIME_SLICE) - if self.fetch_pos +1 <self.content_length: + if self.fetch_pos +1 <self.content_length and not self.channel.is_closed: print self, "start new fetcher" start = self.fetch_pos if self.fetch_pos+self.endpoints_blocksize[endpoint] < self.content_length: |