aioqzone-feed Messages

aioqzone-feed uses tylisten to dispatch and subscribte messages.

Feed Messages

class aioqzone_feed.message.feed.FeedApiEmitterMixin(*args, **kwds)

feed_dropped

This emitter is triggered when a feed is dropped.

feed_processed

This emitter is triggered when a feed is processed.

feed_media_updated

This emitter is triggered when a feed's media is updated.

stop_fetch

This hook is used to determin whether a fetch should stop.

ch_feed_notify

A future store serves as message notify channel.

stop()

Clear future stores.

Heartbeat Messages

class aioqzone_feed.message.heartbeat.HeartbeatEmitterMixin(*args, **kwds)

hb_failed

This emitter is triggered when the heartbeat fails because of a exception.

hb_refresh

This emitter is triggered after a heartbeat succeeded and there are new feeds. Use this event to wait for all dispatch task to be finished, and send received feeds.

ch_heartbeat_notify

A future store serves as heartbeat channel.

stop()

Clear future stores.