在asyncio架构中使用subscribe()方法的方案可行性咨询

我想在一个以asyncio作为I/O并发核心的应用里用上Google Pub/Sub，不过遇到了点麻烦：默认的Google SDK没提供异步方法，之前试过gcloud-aio-pubsub，但它只支持拉取模式，延迟表现实在拉胯。

目前消息发布、主题和订阅管理这块我已经有思路了，用wrap_future就行——毕竟publish()这类方法返回的对象都支持Future协议，适配起来没太大问题。

现在卡在subscribe方法上了：看文档说它会在单独线程里跑StreamingPull，而且从代码里看，回调函数是在线程池的线程里被调用的。我琢磨着能不能把默认的Scheduler替换成自定义的版本，让它在主线程的事件循环里调度协程，这样就能和asyncio配合起来了。

想问问大家这个方案可行吗？有没有什么需要重点注意的坑或者细节？

备注：内容来源于stack exchange，提问作者zefciu