automatically close this channel once the outgoing queue is empty
(self)
| 225 | return self.producer_fifo or (not self.connected) |
| 226 | |
| 227 | def close_when_done(self): |
| 228 | "automatically close this channel once the outgoing queue is empty" |
| 229 | self.producer_fifo.append(None) |
| 230 | |
| 231 | def initiate_send(self): |
| 232 | while self.producer_fifo and self.connected: |