Homofilter

HomoFilter class

source

HomoFilter

 HomoFilter ()

Homoegeneous filter class with the same type for input and output.


source

HomoFilter.filter

 HomoFilter.filter
                    (in_pipeline:tspace.dataflow.pipeline.queue.Pipeline[~
                    T], out_pipeline:tspace.dataflow.pipeline.queue.Pipeli
                    ne[~T], 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

Type Details
in_pipeline Pipeline
out_pipeline Pipeline output pipeline
start_event Optional
stop_event Optional
interrupt_event Optional input event
flash_event Optional
exit_event Optional
Returns None