Stream processing toolkit