raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

=str use Scala's ThreadLocalRandom, because Java 6

Browse source
This commit is contained in:
Konrad Malawski 2015-11-30 14:54:03 +01:00
parent f76061e7f7
commit fc3ba69b6d
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-stream/src/main/scala/akka/stream/impl/fusing/ActorGraphInterpreter.scala
View file

@ -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
/**