Filter

ABC Filter class

Filter

 Filter ()

Filter consume data into the pipeline. It provides a shared interface for signal processing units filter().

source

Filter.filter

 Filter.filter (in_pipeline:Union[tspace.dataflow.pipeline.deque.PipelineD
                Q[~T_RAW],tspace.dataflow.pipeline.queue.Pipeline[~T]],
                out_pipeline:tspace.dataflow.pipeline.queue.Pipeline[~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])

filter data from in_pipeline to out_pipeline

	Type	Details
in_pipeline	Union
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