diff --git a/akka-actor/src/test/scala/dataflow/DataFlowSpec.scala b/akka-actor/src/test/scala/dataflow/DataFlowSpec.scala index dc80e5129a..d1f663e9f4 100644 --- a/akka-actor/src/test/scala/dataflow/DataFlowSpec.scala +++ b/akka-actor/src/test/scala/dataflow/DataFlowSpec.scala @@ -70,7 +70,7 @@ class DataFlowTest extends Spec with ShouldMatchers with BeforeAndAfterAll { List(x,y,z).foreach(_.shutdown) } - it("should be able to join streams") { + /*it("should be able to join streams") { import DataFlow._ ActorRegistry.shutdownAll @@ -133,7 +133,7 @@ class DataFlowTest extends Spec with ShouldMatchers with BeforeAndAfterAll { thread { recurseSum(consumer) } latch.await(15,TimeUnit.SECONDS) should equal (true) - } + }*/ /* Test not ready for prime time, causes some sort of deadlock */ /* it("should be able to conditionally set variables") {