Created
December 10, 2014 22:20
-
-
Save ktoso/da6f5c79b15ac1261e91 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
G] Running: | |
Command line suite | |
[info] - createPublisher1MustProduceAStreamOfExactly1Element | |
[info] - createPublisher3MustProduceAStreamOfExactly3Elements | |
[info] - spec101_subscriptionRequestMustResultInTheCorrectNumberOfProducedElements | |
[info] - spec102_maySignalLessThanRequestedAndTerminateSubscription | |
[info] - spec103_mustSignalOnMethodsSequentially !!! IGNORED !!! | |
[info] - spec104_mustSignalOnErrorWhenFails | |
[info] - spec105_mustSignalOnCompleteWhenFiniteStreamTerminates | |
[info] - spec106_mustConsiderSubscriptionCancelledAfterOnErrorOrOnCompleteHasBeenCalled !!! IGNORED !!! | |
[info] - spec107_mustNotEmitFurtherSignalsOnceOnCompleteHasBeenSignalled | |
[info] - spec107_mustNotEmitFurtherSignalsOnceOnErrorHasBeenSignalled !!! IGNORED !!! | |
[info] - spec108_possiblyCanceledSubscriptionShouldNotReceiveOnErrorOrOnCompleteSignals !!! IGNORED !!! | |
[info] - spec109_subscribeShouldNotThrowNonFatalThrowable !!! IGNORED !!! | |
[info] - spec110_rejectASubscriptionRequestIfTheSameSubscriberSubscribesTwice | |
[info] - spec111_maySupportMultiSubscribe !!! IGNORED !!! | |
[info] - spec112_mayRejectCallsToSubscribeIfPublisherIsUnableOrUnwillingToServeThemRejectionMustTriggerOnErrorInsteadOfOnSubscribe | |
[info] - spec113_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfront !!! IGNORED !!! | |
[info] - spec113_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingOneByOne !!! IGNORED !!! | |
[info] - spec302_mustAllowSynchronousRequestCallsFromOnNextAndOnSubscribe | |
[info] - spec303_mustNotAllowUnboundedRecursion | |
[info] - spec304_requestShouldNotPerformHeavyComputations !!! IGNORED !!! | |
[info] - spec305_cancelMustNotSynchronouslyPerformHeavyCompuatation !!! IGNORED !!! | |
[info] - spec306_afterSubscriptionIsCancelledRequestMustBeNops | |
[info] - spec307_afterSubscriptionIsCancelledAdditionalCancelationsMustBeNops | |
[info] - spec309_requestNegativeNumberMustSignalIllegalArgumentException | |
[info] - spec309_requestZeroMustSignalIllegalArgumentException | |
[info] - spec312_cancelMustMakeThePublisherToEventuallyStopSignaling | |
[info] - spec313_cancelMustMakeThePublisherEventuallyDropAllReferencesToTheSubscriber | |
[ERROR] [12/10/2014 23:19:40.248] [IterablePublisherTest-akka.actor.default-dispatcher-3] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.253] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.254] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.254] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.255] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.255] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.255] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.255] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.255] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.255] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.256] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.256] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.256] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.256] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.256] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.257] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.257] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.257] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.257] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.257] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.257] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.257] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.258] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.258] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.258] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.258] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.258] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.258] [IterablePublisherTest-akka.actor.default-dispatcher-4] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.259] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.259] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.259] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.259] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.260] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.260] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.260] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.260] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.260] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.260] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.261] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.261] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.261] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.261] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.261] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.262] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.262] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.262] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.262] [IterablePublisherTest-akka.actor.default-dispatcher-3] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.262] [IterablePublisherTest-akka.actor.default-dispatcher-3] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.263] [IterablePublisherTest-akka.actor.default-dispatcher-3] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.263] [IterablePublisherTest-akka.actor.default-dispatcher-3] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.263] [IterablePublisherTest-akka.actor.default-dispatcher-3] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.263] [IterablePublisherTest-akka.actor.default-dispatcher-3] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.263] [IterablePublisherTest-akka.actor.default-dispatcher-3] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.263] [IterablePublisherTest-akka.actor.default-dispatcher-3] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.263] [IterablePublisherTest-akka.actor.default-dispatcher-3] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.264] [IterablePublisherTest-akka.actor.default-dispatcher-3] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.264] [IterablePublisherTest-akka.actor.default-dispatcher-3] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.264] [IterablePublisherTest-akka.actor.default-dispatcher-3] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.264] [IterablePublisherTest-akka.actor.default-dispatcher-3] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.264] [IterablePublisherTest-akka.actor.default-dispatcher-3] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.264] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.265] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.265] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.265] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.265] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.265] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.265] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.266] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.266] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.266] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.266] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.266] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.266] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.267] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.267] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.267] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.267] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.267] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.267] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.268] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.268] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.268] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.268] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.268] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.268] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.269] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.269] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.269] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.269] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.269] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.269] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.269] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.270] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.270] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.270] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.270] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.271] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.271] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.271] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.271] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.271] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.271] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.271] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.272] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.272] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[ERROR] [12/10/2014 23:19:40.272] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[info] - spec317_mustSignalOnErrorWhenPendingAboveLongMaxValue | |
[ERROR] [12/10/2014 23:19:40.272] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[info] - spec317_mustSupportACumulativePendingElementCountUpToLongMaxValue | |
[ERROR] [12/10/2014 23:19:40.272] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[info] - spec317_mustSupportAPendingElementCountUpToLongMaxValue | |
[ERROR] [12/10/2014 23:19:40.272] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[info] - validate_boundedDepthOfOnNextAndRequestRecursion | |
[info] - validate_maxElementsFromPublisher | |
[ERROR] [12/10/2014 23:19:40.272] [IterablePublisherTest-akka.actor.default-dispatcher-2] [akka://IterablePublisherTest/user/$t] onNext must not be called after onError | |
java.lang.IllegalStateException: onNext must not be called after onError | |
at akka.stream.actor.ActorPublisher$class.onNext(ActorPublisher.scala:188) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.onNext(ActorPublisherTest.scala:18) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher$$anonfun$receive$1.applyOrElse(ActorPublisherTest.scala:26) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(ActorPublisherTest.scala:18) | |
at akka.stream.actor.ActorPublisher$class.aroundReceive(ActorPublisher.scala:272) | |
at akka.stream.tck.ActorPublisherTest$TestPublisher.aroundReceive(ActorPublisherTest.scala:18) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:221) | |
at akka.dispatch.Mailbox.exec(Mailbox.scala:231) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
=============================================== | |
Command line suite | |
Total tests run: 32, Failures: 0, Skips: 10 | |
=============================================== | |
Reporter completed abruptly with an exception after receiving event: SuiteCompleted(Ordinal(0, 66),ActorPublisherTest,akka.stream.tck.ActorPublisherTest,Some(akka.stream.tck.ActorPublisherTest),Some(19993),Some(MotionToSuppress),Some(TopOfClass(akka.stream.tck.ActorPublisherTest)),None,None,pool-18-thread-1,1418249981484). | |
java.lang.RuntimeException: unexpected event [TestIgnored(Ordinal(0, 11),ActorPublisherTest,akka.stream.tck.ActorPublisherTest,Some(akka.stream.tck.ActorPublisherTest),spec103_mustSignalOnMethodsSequentially,spec103_mustSignalOnMethodsSequentially,Some(IndentedText(- spec103_mustSignalOnMethodsSequentially,spec103_mustSignalOnMethodsSequentially,1)),Some(TopOfMethod(akka.stream.tck.ActorPublisherTest,public void akka.stream.tck.ActorPublisherTest.spec103_mustSignalOnMethodsSequentially())),None,pool-18-thread-1,1418249963408)] | |
at org.scalatest.tools.JUnitXmlReporter.unexpected(JUnitXmlReporter.scala:495) | |
at org.scalatest.tools.JUnitXmlReporter.processTest(JUnitXmlReporter.scala:326) | |
at org.scalatest.tools.JUnitXmlReporter.getTestsuite(JUnitXmlReporter.scala:166) | |
at org.scalatest.tools.JUnitXmlReporter.writeSuiteFile(JUnitXmlReporter.scala:76) | |
at org.scalatest.tools.JUnitXmlReporter.apply(JUnitXmlReporter.scala:59) | |
at org.scalatest.DispatchReporter$Propagator$$anonfun$run$1.apply(DispatchReporter.scala:240) | |
at org.scalatest.DispatchReporter$Propagator$$anonfun$run$1.apply(DispatchReporter.scala:239) | |
at scala.collection.immutable.List.foreach(List.scala:318) | |
at org.scalatest.DispatchReporter$Propagator.run(DispatchReporter.scala:239) | |
at java.lang.Thread.run(Thread.java:745) | |
[info] ActorSubscriberOneByOneRequestTest: | |
[TestNG] Running: | |
Command line suite |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment