The response tracking logic in the streaming endpoints does not reset the blocksSinceLastMessage variable when messages are sent. This could result in unnecessary heartbeat messages getting sent. This is fairly benign, but we may as well fix it.

For example:

This should be

if len(resp.Events) == 0 {
	blocksSinceLastMessage++
	if blocksSinceLastMessage < heartbeatInterval {
		return nil
	}
}
blocksSinceLastMessage = 0

This ensures that blocksSinceLastMessage is reset whenever a response is sent.