From fc3ba69b6d81deefb848dd32a99b42d9a13699eb Mon Sep 17 00:00:00 2001 From: Konrad Malawski Date: Mon, 30 Nov 2015 14:54:03 +0100 Subject: [PATCH] =str use Scala's ThreadLocalRandom, because Java 6 --- .../scala/akka/stream/impl/fusing/ActorGraphInterpreter.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/akka-stream/src/main/scala/akka/stream/impl/fusing/ActorGraphInterpreter.scala b/akka-stream/src/main/scala/akka/stream/impl/fusing/ActorGraphInterpreter.scala index 6bd988061c..4bb626196f 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/fusing/ActorGraphInterpreter.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/fusing/ActorGraphInterpreter.scala @@ -3,7 +3,7 @@ */ package akka.stream.impl.fusing -import java.util.concurrent.{ ThreadLocalRandom, TimeoutException } +import java.util.concurrent.TimeoutException import akka.actor._ import akka.event.Logging @@ -15,6 +15,7 @@ import akka.stream.impl.{ ActorPublisher, ReactiveStreamsCompliance } import akka.stream.stage.{ GraphStageLogic, InHandler, OutHandler } import org.reactivestreams.{ Subscriber, Subscription } +import scala.concurrent.forkjoin.ThreadLocalRandom import scala.util.control.NonFatal /**