LoggingExecutionContext.scala

class LoggingExecutionContext(ec: ExecutionContext) extends ExecutionContext {
  override def execute(runnable: Runnable): Unit = {
    val context = LoggingContext.localContext.value
    ec.execute(new WrappedRunnable(runnable, context))
  }

  override def reportFailure(cause: Throwable): Unit = ec.reportFailure(cause)
}