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

=pro Upgrade akka-stream dependencies to akka 2.3.3

Browse source 
* Upgrade dependency to akka 2.3.3
* Remove javadsl.Pair and javadsl.Predicate in favor of akka.japi.*
This commit is contained in:
Björn Antonsson 2014-05-22 13:53:08 +02:00
parent 7d2186c73d
commit 4f55b0d2e1
4 changed files with 8 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream/src/main/scala/akka/stream/javadsl/Duct.scala
View file

@ -11,6 +11,8 @@ import org.reactivestreams.api.Consumer
import org.reactivestreams.api.Producer
import akka.japi.Function
import akka.japi.Function2
import akka.japi.Pair
import akka.japi.Predicate
import akka.japi.Procedure
import akka.japi.Util.immutableSeq
import akka.stream.FlowMaterializer

16
akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala
View file

@ -12,13 +12,14 @@ import scala.util.Success
import org.reactivestreams.api.Producer
import akka.japi.Function
import akka.japi.Function2
import akka.japi.Pair
import akka.japi.Predicate
import akka.japi.Procedure
import akka.japi.Util.immutableSeq
import akka.stream.FlowMaterializer
import akka.stream.scaladsl.{ Flow ⇒ SFlow }
import akka.stream.Transformer
import org.reactivestreams.api.Consumer
import akka.stream.impl.DuctImpl
/**
* Java API
@ -306,19 +307,6 @@ trait OnCompleteCallback {
def onComplete(e: Throwable)
}
/**
* Java API: Represents a tuple of two elements.
*/
case class Pair[A, B](first: A, second: B) // FIXME move this to akka.japi.Pair in akka-actor
/**
* Java API: Defines a criteria and determines whether the parameter meets this criteria.
*/
trait Predicate[T] {
// FIXME move this to akka.japi.Predicate in akka-actor
def test(param: T): Boolean
}
/**
* INTERNAL API
*/

2
akka-stream/src/test/java/akka/stream/javadsl/DuctTest.java
View file

@ -25,6 +25,8 @@ import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.japi.Function;
import akka.japi.Function2;
import akka.japi.Pair;
import akka.japi.Predicate;
import akka.japi.Procedure;
import akka.japi.Util;
import akka.stream.FlowMaterializer;

2
akka-stream/src/test/java/akka/stream/javadsl/FlowTest.java
View file

@ -25,6 +25,8 @@ import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.japi.Function;
import akka.japi.Function2;
import akka.japi.Pair;
import akka.japi.Predicate;
import akka.japi.Procedure;
import akka.japi.Util;
import akka.stream.FlowMaterializer;