Horizon component for processing published events and performing demultiplexing and filtering tasks - View it on GitHub