This doesn't signal anywhere that an error occurred and then ends the listening goroutine. I think that will just leave any subscribers hanging?