Instead of waiting till we reach EOS in one goroutine and concurrently looping through the already responded events in another goroutine, we can just block till we reach EOS in the same goroutine and then loop through events. That way we don't even have to check if it reached EOS.
And hence removes the need of an additional go routine and the unnecessary check for ReceivedEOS and also removes it from the Service model as a whole.
Instead of waiting till we reach EOS in one goroutine and concurrently looping through the already responded events in another goroutine, we can just block till we reach EOS in the same goroutine and then loop through events. That way we don't even have to check if it reached EOS.
And hence removes the need of an additional go routine and the unnecessary check for ReceivedEOS and also removes it from the Service model as a whole.