Module: cogen.core.pubsub

Classes

PublishSubscribeQueue

A more robust replacement for the signal operations. A coroutine subscribes itself to a PublishSubscribeQueue and get new published messages with _fetch_ method.