Semi independent components to process and filter data streams. Uses great Celluloid library  https://github.com/celluloid/celluloid