Implement event stream writer