Homofilter
HomoFilter class
HomoFilter
HomoFilter ()
Homoegeneous filter class with the same type for input and output.
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 |