pm4py.streaming.stream.live_event_stream module
-
class pm4py.streaming.stream.live_event_stream.StreamState(*values)[source]
Bases: Enum
-
INACTIVE = 1
-
ACTIVE = 2
-
FINISHED = 3
-
class pm4py.streaming.stream.live_event_stream.Parameters(*values)[source]
Bases: Enum
-
THREAD_POOL_SIZE = 'thread_pool_size'
-
class pm4py.streaming.stream.live_event_stream.LiveEventStream(parameters=None)[source]
Bases: object
-
append(event)[source]
-
start()[source]
-
stop()[source]
-
register(algo)[source]
-
async deregister(algo)[source]
-
property state
