Lightweight Distributed Stream processor (erlang)