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 |