code: def restart_writing(self, task=None):
          
          if self._restart_writer:
              self._writer_task = asyncio.ensure_future(
                  self._get_message_from_send_queue(), loop=self._loop)
              self._writer_task.add_done_callback(self.restart_writing)
docs: Resume writing.