event stream divider implementaion first draft