smart stream processing