Improve reliability of frontend stream handling (gets rid of some duplicated messages due to server errors in the streams)