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

#19440 Added scala-java8-compat as a dependency to streams

Browse source
This commit is contained in:
Endre Sándor Varga 2016-01-14 11:25:56 +01:00
parent e92429dab9
commit b217e2e480
3 changed files with 8 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-stream-tests/src/test/scala/akka/stream/impl/fusing/ActorGraphInterpreterSpec.scala
View file

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

2
akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala
View file

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

6
project/Dependencies.scala
View file

@ -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)