diff --git a/akka-stream-tests/src/test/scala/akka/stream/impl/fusing/ActorGraphInterpreterSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/impl/fusing/ActorGraphInterpreterSpec.scala
index 9c656f0006..d6f2ae0378 100644
--- a/akka-stream-tests/src/test/scala/akka/stream/impl/fusing/ActorGraphInterpreterSpec.scala
+++ b/akka-stream-tests/src/test/scala/akka/stream/impl/fusing/ActorGraphInterpreterSpec.scala
@@ -7,9 +7,9 @@ import java.util.concurrent.CountDownLatch
 
 import akka.stream._
 import akka.stream.scaladsl._
-import akka.stream.stage.{GraphStage, GraphStageLogic, InHandler, OutHandler}
+import akka.stream.stage.{ GraphStage, GraphStageLogic, InHandler, OutHandler }
 import akka.stream.testkit.Utils._
-import akka.stream.testkit.{AkkaSpec, TestPublisher, TestSubscriber}
+import akka.stream.testkit.{ AkkaSpec, TestPublisher, TestSubscriber }
 import akka.testkit.EventFilter
 
 import scala.concurrent.Await
diff --git a/akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala b/akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala
index c361f85c3b..067bcd9461 100644
--- a/akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala
+++ b/akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala
@@ -239,7 +239,7 @@ object Source {
    */
   def repeat[T](element: T): Source[T, Unit] = {
     val next = Some((element, element))
-    unfold(element)(_ => next).withAttributes(DefaultAttributes.repeat)
+    unfold(element)(_ ⇒ next).withAttributes(DefaultAttributes.repeat)
   }
 
   /**
diff --git a/project/Dependencies.scala b/project/Dependencies.scala
index 2b739efcaa..f5163f074f 100644
--- a/project/Dependencies.scala
+++ b/project/Dependencies.scala
@@ -54,7 +54,10 @@ object Dependencies {
     val jackson     = "com.fasterxml.jackson.core"    % "jackson-databind"             % "2.4.3"       // ApacheV2
 
     // For akka-http-testkit-java
-     val junit       = "junit"                         % "junit"                        % "4.11"        // Common Public License 1.0
+    val junit       = "junit"                         % "junit"                        % "4.11"        // Common Public License 1.0
+
+    // For Java 8 Conversions
+    val java8Compat = "org.scala-lang.modules"       %% "scala-java8-compat"           % "0.7.0"       // Scala License
 
     object Docs {
       val sprayJson   = "io.spray"                   %%  "spray-json"                  % "1.3.2"             % "test"
@@ -182,6 +185,7 @@ object Dependencies {
   lazy val stream = l ++= Seq[sbt.ModuleID](
     sslConfigAkka,
     reactiveStreams,
+    java8Compat,
     Test.junitIntf,
     Test.scalatest.value)