Old loop would leave a client hanging when invalid JSON was entered.
This commit refactors the whole loop to avoid that, ensuring even bad
disconnects clean up any subscribers.