You need to implement this function to fix "TOO_MANY_ACTIVE_STREAMS" issue @inks007 about crunpyroll HOT 6 CLOSED

import crunpyroll
import asyncio
import sys
import os
import requests
from pywidevine.cdm import Cdm
from pywidevine.pssh import PSSH
from pywidevine.device import Device
from uuid import uuid4

client = crunpyroll.Client(
*
*
*
)

async def main():
	await client.start()
*
*
*
	#We launch the download
	# yt_dlp_url contains download instructions with yt_dlp.exe
	os.system(yt_dlp_url)
	
	# We wait for it to finish downloading
	await client.delete_active_stream(
	streams.media_id,
	token=streams.token
	)


	# Get Widevine PSSH from manifest
*
*
*
	cdm.parse_license(session_id, license)
	print()
	for key in cdm.get_keys(session_id, "CONTENT"):
		print((f"{key.kid.hex}:{key.key.hex()}"),file=open('./Temporales/Key.txt','a'))
	cdm.close(session_id)

asyncio.run(main())

  File "E:\Crunchy Videos\Temporales\crunpyroll_cr2.py", line 117, in <module>
    asyncio.run(main())
  File "C:\Python311\Lib\asyncio\runners.py", line 190, in run
    return runner.run(main)
           ^^^^^^^^^^^^^^^^
  File "C:\Python311\Lib\asyncio\runners.py", line 118, in run
    return self._loop.run_until_complete(task)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Python311\Lib\asyncio\base_events.py", line 653, in run_until_complete
    return future.result()
           ^^^^^^^^^^^^^^^
  File "E:\Crunchy Videos\Temporales\crunpyroll_cr2.py", line 106, in main
    license = await client.get_license(
              ^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Python311\Lib\site-packages\crunpyroll\methods\get_license.py", line 34, in get_license
    response = await self.api_request(
               ^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Python311\Lib\site-packages\crunpyroll\client.py", line 117, in api_request
    return Client.parse_response(response, method=method)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Python311\Lib\site-packages\crunpyroll\client.py", line 90, in parse_response
    raise CrunpyrollException(message)
crunpyroll.errors.CrunpyrollException: [401] "Unauthorized"`

	cdm.parse_license(session_id, license)
	print()
	for key in cdm.get_keys(session_id, "CONTENT"):
		print((f"{key.kid.hex}:{key.key.hex()}"),file=open('./Temporales/Key.txt','a'))
	cdm.close(session_id)
	
	# We wait for it to finish downloading
	await client.delete_active_stream(
	streams.media_id,
	token=streams.token
	)
	
asyncio.run(main())

from uuid import uuid4
print(str(uuid4()))