Implement event stream processing