fixed eventstream processing to deal with events arriving in parts