Problem running the app on Windows

[IlyaKhramtsov]

Hi all, I created a test app using the example from the documentation.
When I try to run the app, the error "NotImplementedError" appears.

Example:

from faststream import FastStream
from faststream.rabbit import RabbitBroker

broker = RabbitBroker("amqp://guest:guest@localhost:5672/")

app = FastStream(broker)


@broker.subscriber("in")
@broker.publisher("out")
async def handle_msg(user: str, user_id: int) -> str:
    return f"User: {user_id} - {user} registered"

Output:

(test-app-py3.11) PS D:\projects\test-app> faststream run app:app
2024-01-17 13:58:33,878 INFO     - FastStream app starting...
Traceback (most recent call last):

  File "<frozen runpy>", line 198, in _run_module_as_main

  File "<frozen runpy>", line 88, in _run_code

  File "D:\projects\test-app\.venv\Scripts\faststream.exe\__main__.py", line 7, in <module>
    sys.exit(cli())
             ^^^^^

  File "D:\projects\test-app\.venv\Lib\site-packages\faststream\cli\main.py", line 149, in run
    _run(*args)

  File "D:\projects\test-app\.venv\Lib\site-packages\faststream\cli\main.py", line 184, in _run
    anyio.run(

  File "D:\projects\test-app\.venv\Lib\site-packages\anyio\_core\_eventloop.py", line 73, in run
    return async_backend.run(func, args, {}, backend_options)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

  File "D:\projects\test-app\.venv\Lib\site-packages\anyio\_backends\_asyncio.py", line 1991, in run
    return runner.run(wrapper())
           ^^^^^^^^^^^^^^^^^^^^^

  File "C:\Users\elijah\AppData\Local\Programs\Python\Python311\Lib\asyncio\runners.py", line 118, in run
    return self._loop.run_until_complete(task)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

  File "C:\Users\elijah\AppData\Local\Programs\Python\Python311\Lib\asyncio\base_events.py", line 653, in run_until_complete
    return future.result()
           ^^^^^^^^^^^^^^^

  File "D:\projects\test-app\.venv\Lib\site-packages\anyio\_backends\_asyncio.py", line 1979, in wrapper
    return await func(*args)
           ^^^^^^^^^^^^^^^^^

  File "D:\projects\test-app\.venv\Lib\site-packages\faststream\app.py", line 344, in run
    raise ex from None

  File "D:\projects\test-app\.venv\Lib\site-packages\faststream\app.py", line 340, in run
    await self._stop(log_level)

  File "D:\projects\test-app\.venv\Lib\site-packages\faststream\app.py", line 375, in _stop
    with anyio.open_signal_receiver(*HANDLED_SIGNALS) as signals:

  File "D:\projects\test-app\.venv\Lib\site-packages\anyio\_backends\_asyncio.py", line 1784, in __enter__
    self._loop.add_signal_handler(sig, self._deliver, sig)

  File "C:\Users\elijah\AppData\Local\Programs\Python\Python311\Lib\asyncio\events.py", line 574, in add_signal_handler
    raise NotImplementedError

NotImplementedError

What could be wrong?

[Lancetnik]

@IlyaKhramtsov Please, update FastStream to 0.3.14
This is just 0.3.13 but, sorry