Heterofilter

HeteroFilter class

source

HeteroFilter

 HeteroFilter ()

Hetereofilter is a filter that consumes data from a pipeline and produces data to another pipeline with a different type.


source

HeteroFilter.filter

 HeteroFilter.filter
                      (in_pipeline:tspace.dataflow.pipeline.deque.Pipeline
                      DQ[~T_I], out_pipeline:tspace.dataflow.pipeline.queu
                      e.Pipeline[~T_O],
                      start_event:Optional[threading.Event],
                      stop_event:Optional[threading.Event],
                      interrupt_event:Optional[threading.Event],
                      flash_event:Optional[threading.Event],
                      exit_event:Optional[threading.Event])

consume data into the pipeline, and produce data to the output pipeline

Type Details
in_pipeline PipelineDQ
out_pipeline Pipeline output pipeline
start_event Optional input event start
stop_event Optional input event stop
interrupt_event Optional input event interrupt
flash_event Optional input event flash
exit_event Optional input event exit
Returns None