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

Merge pull request #19175 from drewhk/wip-19067-interpreter-double-fault-drewhk

Browse source 
=str #19067: Fixed error reporting after stage is closed.
This commit is contained in:
drewhk 2015-12-16 09:10:50 +01:00
commit caa7e68893
6 changed files with 50 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

9
akka-stream-tests/src/test/scala/akka/stream/impl/fusing/GraphInterpreterSpecKit.scala
View file

@ -11,9 +11,10 @@ import akka.stream.stage.{ GraphStage, GraphStageLogic, InHandler, OutHandler, _
import akka.stream.testkit.AkkaSpec
import akka.stream.testkit.Utils.TE
import akka.stream.impl.fusing.GraphInterpreter.GraphAssembly
import akka.event.NoLogging
trait GraphInterpreterSpecKit {
trait GraphInterpreterSpecKit extends AkkaSpec {
val logger = Logging(system, "InterpreterSpecKit")
abstract class Builder {
private var _interpreter: GraphInterpreter = _
@ -72,7 +73,7 @@ trait GraphInterpreterSpecKit {
val (inHandlers, outHandlers, logics) =
assembly.materialize(Attributes.none, assembly.stages.map(_.module), new java.util.HashMap, _ ⇒ ())
_interpreter = new GraphInterpreter(assembly, NoMaterializer, NoLogging, inHandlers, outHandlers, logics,
_interpreter = new GraphInterpreter(assembly, NoMaterializer, logger, inHandlers, outHandlers, logics,
(_, _, _) ⇒ (), fuzzingMode = false)
for ((upstream, i) ← upstreams.zipWithIndex) {
@ -90,7 +91,7 @@ trait GraphInterpreterSpecKit {
def manualInit(assembly: GraphAssembly): Unit = {
val (inHandlers, outHandlers, logics) =
assembly.materialize(Attributes.none, assembly.stages.map(_.module), new java.util.HashMap, _ ⇒ ())
_interpreter = new GraphInterpreter(assembly, NoMaterializer, NoLogging, inHandlers, outHandlers, logics,
_interpreter = new GraphInterpreter(assembly, NoMaterializer, logger, inHandlers, outHandlers, logics,
(_, _, _) ⇒ (), fuzzingMode = false)
}