1.1.4. utils.queue_network package¶

1.1.4.1. Submodules¶

1.1.4.1.1. radical.utils.queue_network.network module¶

class radical.utils.queue_network.network.Network(state_model=None, network_description=None)[source]¶

Bases: object

feed(entities)[source]¶: feed entities into the network

subscribe(states, callback)[source]¶: subscribe for callback notifications for state transitions into the specified states. If callbacks return ‘False’ or ‘None’, they are unregistered.

1.1.4.1.2. radical.utils.queue_network.node module¶

class radical.utils.queue_network.node.Node[source]¶: Bases: object

1.1.4.1.3. radical.utils.queue_network.queue module¶

class radical.utils.queue_network.queue.Queue[source]¶: Bases: object