A5rocks

# pretty basic backpressured pubsub
import trio
import typing


class PubSub:
    topics_to_channels: typing.MutableMapping[
        str,
        typing.List[trio.MemorySendChannel]
    ]