bec_lib.redis_connector.DirectReadingStreamSubscriptionInfo

class DirectReadingStreamSubscriptionInfo(id: 'str', topic: 'str', newest_only: 'bool', from_start: 'bool', cb_ref: 'callable', kwargs: 'dict')

Bases: StreamSubscriptionInfo

Methods

Attributes

stop_event
thread
id
topic
newest_only
from_start
cb_ref
kwargs