Catch and close on unicode errors in stream

		assert self.sock is not None, \

			"RuntimeError should have been raised by a public method if self.sock is None"

		try:

			msg = (await self.sock.receive()).decode().strip()

		except (UnicodeDecodeError, anyio.EndOfStream):

			await self.sock.aclose()

			raise anyio.ClosedResourceError

		self.logger.debug("Received: %s", repr(msg))

		match = self.event_regex.match(msg)