Hello hAkkers,
I've got some filter-like bidi-stage that filters elements of second flow
based on elements from first one. Like this:
final class IOFilter[O] extends GraphStage[BidiShape[O, O, O, O]] {
val inO1: Inlet[O] = Inlet("IOFilter.inO1")
val inO2: Inlet[O] = Inlet("IOFilter.inO2")
val outO1: Outlet[O] = Outlet[O]("IOFilter.outO1")
val outO2: Outlet[O] = Outlet[Response[I]]("IOFilter.outO2")
val shape = BidiShape(inO1, outO1, inO2, outO2)
def createLogic(inheritedAttributes: Attributes): GraphStageLogic =
new GraphStageLogic(shape) with StageLogging {
private var value: O = _
setHandler(outO1, () => pull(inO1))
setHandler(
inO1,
new InHandler {
override def onPush(): Unit = {
value = grab(inO1)
push(outO1, value)
maybePullO2()
}
override def onUpstreamFinish(): Unit = complete(outO1)
}
)
setHandler(outO2, () => maybePullO2())
setHandler(
inO2,
new InHandler {
override def onPush(): Unit = {
if (value == grab(inO2)) {
emit(outO2, value)
if (isClosed(inO1)) completeStage()
} else maybePullO2()
}
}
)
private def maybePullO2(): Unit = if (value != null) pull(inO2)
}
}
The problem is that after completion of 'outO2' outlet I receive log
message about `Message
[akka.stream.impl.fusing.ActorGraphInterpreter$Resume$] was not delivered:
akka.actor.RepointableActorRef - Message
[akka.stream.impl.fusing.ActorGraphInterpreter$Resume$] from
Actor[akka://pricing/user/StreamSupervisor-2/pricing-71-0-unknown-
operation#-1846184194] to
Actor[akka://pricing/user/StreamSupervisor-2/pricing-71-0-unknown-operation#-1846184194]
was not delivered. [3] dead letters encountered. This logging can be turned
off or adjusted with configuration settings 'akka.log-dead-letters' and
'akka.log-dead-letters-during-shutdown'.
This message do not appear if I do not complete stage after first flow
completion but since second flow is potentially infinite it is not safe to
do so.
Do I need to worry about this message or it is safe just to skip it?
Java 8, Scala 2.12.2, Akka 2.4.18.
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
