Mark body as complete (called when message ends).
(self)
| 191 | self._wake_waiter() |
| 192 | |
| 193 | def set_complete(self): |
| 194 | """Mark body as complete (called when message ends).""" |
| 195 | self._complete = True |
| 196 | self._wake_waiter() |
| 197 | |
| 198 | def signal_disconnect(self): |
| 199 | """Signal that the client transport has gone away.""" |