code: async def close(self):
          
          push_connection = self.pubsub.push_connection
          self.status = self.statusType.closed
          if push_connection:
              push_connection.event('connection_lost').unbind(
                  self._connection_lost
              )
              await self.pubsub.close()
docs: Close channels and underlying pubsub handler
  
          :return: a coroutine and therefore it must be awaited