equal
deleted
inserted
replaced
188 def __iter__(self): |
188 def __iter__(self): |
189 for cnxset in self._cnxsets: |
189 for cnxset in self._cnxsets: |
190 yield cnxset |
190 yield cnxset |
191 |
191 |
192 def close(self): |
192 def close(self): |
|
193 # XXX we don't close the connection when there is no queue? |
193 if self._queue is not None: |
194 if self._queue is not None: |
194 while not self._queue.empty(): |
195 while not self._queue.empty(): |
195 cnxset = self._queue.get_nowait() |
196 cnxset = self._queue.get_nowait() |
196 |
197 |
197 try: |
198 try: |