code: async def close(self, *, force_after=30):
          '''Close the connection and return when closed.'''
          if self.transport:
              self.transport.close()
              try:
                  async with timeout_after(force_after):
                      await self.closed_event.wait()
              except TaskTimeout:
                  self.abort()
                  await self.closed_event.wait(ync def close(self, *, force_after=30):
          '''Close the connection and return when closed.'''
          if self.transport:
              self.transport.close()
              try:
                  async with timeout_after(force_after):
                      await self.closed_event.wait()
              except TaskTimeout:
                  self.abort()
                  await self.closed_event.wait()
docs: Close the connection and return when closed.