DelayedSubscriber

digraph inheritance4e6ea340c2 { rankdir=UD; ratio=compress; size="8.0, 12.0"; "DelayedSubscriber" [URL="#taurus.qt.qtcore.util.emitter.DelayedSubscriber",color=dodgerblue1,fontcolor=black,fontname="Vera Sans, DejaVu Sans, Liberation Sans, Arial, Helvetica, sans",fontsize=10,height=0.5,shape=box,style=rounded,target="_top",tooltip="DelayedSubscriber(schema) will use a TaurusEmitterThread to perform"]; "Logger" -> "DelayedSubscriber" [arrowsize=0.5,style="setlinewidth(0.5)"]; "Logger" [color=dodgerblue1,fontcolor=black,fontname="Vera Sans, DejaVu Sans, Liberation Sans, Arial, Helvetica, sans",fontsize=10,height=0.5,shape=box,style=rounded,tooltip="The taurus logger class. All taurus pertinent classes should inherit"]; "Object" -> "Logger" [arrowsize=0.5,style="setlinewidth(0.5)"]; "Object" [color=dodgerblue1,fontcolor=black,fontname="Vera Sans, DejaVu Sans, Liberation Sans, Arial, Helvetica, sans",fontsize=10,height=0.5,shape=box,style=rounded]; }
class DelayedSubscriber(schema, parent=None, sleep=10000, pause=5, period=0)[source]

Bases: taurus.core.util.log.Logger

DelayedSubscriber(schema) will use a TaurusEmitterThread to perform a thread safe delayed subscribing on all Attributes of a given Taurus Schema that has not been previously subscribed.

Warning

This class belongs to a “Delayed Event Subscription” API added in v.4.2.1-alpha as an experimental feature. This API may not be stable and/or it may be removed in a future release (even on a minor version change)

addUnsubscribedAttributes()[source]

Schedule subscription for all pending attributes

cleanUp()[source]

The cleanUp. Default implementation does nothing Overwrite when necessary

getUnsubscribedAttributes()[source]

Check all pending subscriptions in the current factory