Support for AsgiFastStream with AppWrapper ?

[yann-combarnous]

Currently, the following errors out, saying that AsgiFastStream is not supported by AppWrapper.

It would be nice to be able to monitor the broker is alive like regular FastSteam broker, for instance with:

app = FastStream(broker, logger=logger).as_asgi(
    asgi_routes=[
        ("/liveness", liveness_ping),
    ],
)
taskiq_broker = AppWrapper(app)

Or maybe by applying asgi to taskiq_broker

[Lancetnik]

@yann-combarnous seems like it works correctly, just a type hints problem

[yann-combarnous]

@yann-combarnous seems like it works correctly, just a type hints problem

That’s correct. On a side note, I also noticed async generator functions also had a type hint issue.

[Lancetnik]

@yann-combarnous seems like it works correctly, just a type hints problem

That’s correct. On a side note, I also noticed async generator functions also had a type hint issue.

Can you create a PR to fix it? Or give me more information about the problem, please (link to the code line or smth)

[yann-combarnous]

@yann-combarnous seems like it works correctly, just a type hints problem

That’s correct. On a side note, I also noticed async generator functions also had a type hint issue.

Can you create a PR to fix it? Or give me more information about the problem, please (link to the code line or smth)

Will check out latest version tomorrow, and create PR if needed.

[yann-combarnous]

@yann-combarnous seems like it works correctly, just a type hints problem

That’s correct. On a side note, I also noticed async generator functions also had a type hint issue.

Can you create a PR to fix it? Or give me more information about the problem, please (link to the code line or smth)

Will check out latest version tomorrow, and create PR if needed.

@Lancetnik , PR added here: #84