Scala, Concurrency, API, Project Loom, Java.
terminated, and interrupting the fork will be caught & logged. The way to fix the above is to catch InterruptedException separately and re-throw it or use NonFatal: scoped { fork { forever { try processSingleItem() catch case NonFatal(e) => logger.error("Processing error", e) } } // do something