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.
A more robust replacement for the signal operations. A coroutine subscribes itself to a PublishSubscribeQueue and get new published messages with _fetch_ method.