[0.9] IllegalStateException "onNext must not be called after onError" in ActorPublisher

[Daenyth]

Kind of useless stack trace;

onNext must not be called after onError
ActorPublisher.scala  199 akka.stream.actor.ActorPublisher.onNext(...)
ActorPublisher.scala:199:in `akka.stream.actor.ActorPublisher.onNext'
ActorPublisher.scala  190 akka.stream.actor.ActorPublisher.onNext$(...)
ActorPublisher.scala:190:in `akka.stream.actor.ActorPublisher.onNext$'
AkkaStreamPublisher.scala  34 streamz.converter.AkkaStreamPublisher.onNext(...)
AkkaStreamPublisher.scala:34:in `streamz.converter.AkkaStreamPublisher.onNext'
AkkaStreamPublisher.scala  48 streamz.converter.AkkaStreamPublisher$$anonfun$receive$1.applyOrElse(...)
AkkaStreamPublisher.scala:48:in `streamz.converter.AkkaStreamPublisher$$anonfun$receive$1.applyOrElse'
Actor.scala  517 akka.actor.Actor.aroundReceive(...)
Actor.scala:517:in `akka.actor.Actor.aroundReceive'
Actor.scala  515 akka.actor.Actor.aroundReceive$(...)
Actor.scala:515:in `akka.actor.Actor.aroundReceive$'
AkkaStreamPublisher.scala  34 streamz.converter.AkkaStreamPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive(...)
AkkaStreamPublisher.scala:34:in `streamz.converter.AkkaStreamPublisher.akka$stream$actor$ActorPublisher$$super$aroundReceive'
ActorPublisher.scala  330 akka.stream.actor.ActorPublisher.aroundReceive(...)
ActorPublisher.scala:330:in `akka.stream.actor.ActorPublisher.aroundReceive'
ActorPublisher.scala  273 akka.stream.actor.ActorPublisher.aroundReceive$(...)
ActorPublisher.scala:273:in `akka.stream.actor.ActorPublisher.aroundReceive$'
AkkaStreamPublisher.scala  34 streamz.converter.AkkaStreamPublisher.aroundReceive(...)
AkkaStreamPublisher.scala:34:in `streamz.converter.AkkaStreamPublisher.aroundReceive'
ActorCell.scala  588 akka.actor.ActorCell.receiveMessage(...)
ActorCell.scala:588:in `akka.actor.ActorCell.receiveMessage'
ActorCell.scala  557 akka.actor.ActorCell.invoke(...)
ActorCell.scala:557:in `akka.actor.ActorCell.invoke'
Mailbox.scala  258 akka.dispatch.Mailbox.processMailbox(...)
Mailbox.scala:258:in `akka.dispatch.Mailbox.processMailbox'
Mailbox.scala  225 akka.dispatch.Mailbox.run(...)
Mailbox.scala:225:in `akka.dispatch.Mailbox.run'
Mailbox.scala  235 akka.dispatch.Mailbox.exec(...)
Mailbox.scala:235:in `akka.dispatch.Mailbox.exec'
ForkJoinTask.java  260 akka.dispatch.forkjoin.ForkJoinTask.doExec(...)
ForkJoinTask.java:260:in `akka.dispatch.forkjoin.ForkJoinTask.doExec'
ForkJoinPool.java  1339 akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(...)
ForkJoinPool.java:1339:in `akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask'
ForkJoinPool.java  1979 akka.dispatch.forkjoin.ForkJoinPool.runWorker(...)
ForkJoinPool.java:1979:in `akka.dispatch.forkjoin.ForkJoinPool.runWorker'
ForkJoinWorkerThread.java  107 akka.dispatch.forkjoin.ForkJoinWorkerThread.run(...)
ForkJoinWorkerThread.java:107:in `akka.dispatch.forkjoin.ForkJoinWorkerThread.run'

This is probably fixed by accident in #43 but I wanted to record it for anyone else on 0.9

[krasserm]

This is for sure fixed with #43. Closing this issue then (added it to 0.10-M2 milestone). Did you see that during a test run or in an application?

[Daenyth]

Saw it in production. Unfortunately we use the converter in a lot of places, so I'm not really sure where it's actually coming from