In using Stream class, how could I handle asyncio.CancellError exception?

[MarkofChina]

I use a module (based on redis) to produce message and sent by sse, after sse error occur or see closed, I have to shut down part of that module.

with using async def, I have no problem, unfortunately, I don't know where to put my shutdown codes in Stream class.

May you help ?

[sysid]

@MarkofChina , this does not look like a sse-starlette issue to me.

[MarkofChina]

thank you sir, you are right saying that, I checked your source code and found actually many ways are available to do that