Data Pools (Core)

Data Pools (Core)#

alts.core.data.data_pools

class DataPools[source]#

Bases: Configurable

Description
A DataPools stores all queries and results that have been supplied to it.
trigger_subscriber() → None[source]#
Description
Subscribee informs about new available data.
class PRDataPools[source]#

Bases: ResultDataPools, ProcessDataPools

Description
A DataPools specifically for immediate and delayed results.
class ProcessDataPools(process)[source]#

Bases: DataPools

Description
A DataPools specifically for immediate results.
Parameters:

process (QueriedDataPool) – The process to be pooled

process: QueriedDataPool = NOTSET#
trigger_subscriber(self) → None[source]#
Description
Informs about new available data in the process.
class ResultDataPools(*args: Any, **kwargs: Any)[source]#

Bases: DataPools

ResultDataPools(result) | Description | A DataPools specifically for results.

Parameters:

result (QueriedDataPool) – The results to be pooled

result: QueriedDataPool = NOTSET#
trigger_subscriber(self) → None[source]#
Description
Informs about new available results.
class SPRDataPools[source]#

Bases: StreamDataPools, PRDataPools

Description
A DataPools specifically for streamed immediate and delayed results.
class StreamDataPools(stream)[source]#

Bases: DataPools

Description
A DataPools specifically for streams.
Parameters:

stream (QueriedDataPool) – The stream to be pooled

stream: QueriedDataPool = NOTSET#
trigger_subscriber(self) → None[source]#
Description
Informs about new available data in the stream.