redis发布订阅如何与SSE或者socketio结合【使用的是flask】?

Question

我想使用SSE/socketio + redis发布订阅来实现消息的推送功能， 下面是我设计的流程图：

可是在实现的过程中卡在了一个地方【自认为这个问题应该很简单，但是就是想了几天都没想出来】：
问题出现在上述步骤的第四步：就是当redis在监听的channel中监听到消息后，怎么发给SSE或者socketio模块来向客户端推送？
我写了一个简单的sse如下【只是一个学习demo】：

在我的程序中sse模块就是个路由函数。咋通知啊？【是不是我对sse的理解有误解】
而且即使通知到了，如何执行sse模块【路由函数】中的程序？这是个路由函数，没有请求的话，怎么执行？

卡在这个问题好几天了，感觉脑子没转过来弯。
实在想不出来了，懂的朋友请讲解下，万分感谢。