Data stream processing engine in progress ... please, stay tuned.