Subscriber (Core)

Subscriber (Core)#

alts.core.subscriber
class DataPoolsSubscriber[source]#

Bases: Subscriber

Description
A Subscriber of DataPools.
data_pools: DataPools#
class ExpModSubscriber[source]#

Bases: Subscriber

Description
A Subscriber of ExperimentModules.
exp_modules: ExperimentModules = Field(name=None,type=None,default=<dataclasses._MISSING_TYPE object>,default_factory=<dataclasses._MISSING_TYPE object>,init=False,repr=False,hash=None,compare=True,metadata=mappingproxy({}),_field_type=None)#
experiment_update(self, subscription) → None[source]#
Description
Tries to update the given subscription.
Parameters:

subscription (Subscribable) – The subscription to be updated

subscribe(self) → None[source]#
Description
Subscribes to its ExperimentDataPools.
class OraclesSubscriber[source]#

Bases: Subscriber

Description
A Subscriber of Oracles.
oracles: Oracles#
class ProcessDataSubscriber[source]#

Bases: DataPoolsSubscriber

Description
A Subscriber of StreamDataPools.
data_pools: ProcessDataPools#
process_update(self, subscription) → None[source]#
Description
Tries to update the given subscription.
Parameters:

subscription (Subscribable) – The subscription to be updated

subscribe(self) → None[source]#
Description
Subscribes to its ProcessDataPools.
class ProcessOracleSubscriber[source]#

Bases: OraclesSubscriber

Description
A Subscriber of POracles.
oracles: POracles#
process_query(self, subscription) → None[source]#
Description
Tries to update the given subscription.
Parameters:

subscription (Subscribable) – The subscription to be updated

subscribe(self) → None[source]#
Description
Subscribes to its Oracles.
class ResultDataSubscriber[source]#

Bases: DataPoolsSubscriber

Description
A Subscriber of ResultDataPools.
data_pools: ResultDataPools#
result_update(self, subscription) → None[source]#
Description
Tries to update the given subscription.
Parameters:

subscription (Subscribable) – The subscription to be updated

subscribe(self) → None[source]#
Description
Subscribes to its ResultDataPools.
class StreamDataSubscriber[source]#

Bases: DataPoolsSubscriber

Description
A Subscriber of StreamDataPools.
data_pools: StreamDataPools#
stream_update(self, subscription) → None[source]#
Description
Tries to update the given subscription.
Parameters:

subscription (Subscribable) – The subscription to be updated

subscribe(self) → None[source]#
Description
Subscribes to its StreamDataPools.
class Subscriber[source]#

Bases: Configurable

Description
A Subscriber is capable of subscribing to a Subscribable and trying to update a Subscribable.
post_init(self) → None[source]#
Description
Initializes the Configurable and subscribes.
abstract subscribe(self) → None[source]#
Description
Subscribes to all necessary things… nothing right now.
Abstract Method
abstract update(self, subscription) → None[source]#
Description
Tries to update the given subscription.
Abstract Method
Parameters:

subscription (Subscribable) – The subscription to be updated

class TimeSubscriber[source]#

Bases: Subscriber

Description
A Subscriber of TimeSource.
subscribe(self) → None[source]#
Description
Subscribes to its TimeSource.
time_source: TimeSource = Field(name=None,type=None,default=<dataclasses._MISSING_TYPE object>,default_factory=<dataclasses._MISSING_TYPE object>,init=False,repr=False,hash=None,compare=True,metadata=mappingproxy({}),_field_type=None)#
time_update(self, subscription) → None[source]#
Description
Tries to update the given subscription.
Parameters:

subscription (Subscribable) – The subscription to be updated