code: async def clean_up_clients_async(self):
          
          if self.partition_receiver:
              if self.eh_client:
                  await self.eh_client.stop_async()
                  self.partition_receiver = None
                  self.partition_receive_handler = None
                  self.eh_client = None
docs: Resets the pump swallows all exceptions.