handle incoming end without feeding messages back into itself
disconnect stream instead of crashing on invalid message
1.5.3