Hey @dysbulic,
As a workaround, I use PostgreSQL CDC, Kafka Connect, and Apache Kafka to achieve a form of pub/sub functionality. Then I handle my subscription logic separately.
I believe tasks like these will become easier once the Ceramic API is released.