Minor change: using EitherT to break from loop in threads.