David, does your flow contain an actual internal feedback loop? What I
understand from your description is that you have something like this:
{ tick source ~> mapAsync calling external service ~> } ~> consumer
And your return the Cancellable provided by the tick source as materialized
value as your flow's materialized value. I think in this case, calling
cancel() on that returned value should complete the whole flow without
problems. If this is not the case, it would be best if you showed some code
:)
By the way, is there an issue for producing custom materialized values from
user-defined graphs? I browsed through the 'streams-*' milestones and I was
unable to find it. Should I file one?
cheers,
Rafał
W dniu niedziela, 26 lipca 2015 10:24:06 UTC+2 użytkownik David Pinn
napisał:
>
> The JavaDoc for the Source.from(...) method says this: "Elements are
> emitted periodically with the specified interval. The tick element will be
> delivered to downstream consumers that has requested any elements. If a
> consumer has not requested any elements at the point in time when the tick
> element is produced it will not receive that tick element later. It will
> receive new tick elements as soon as it has requested more elements."
>
> There's nothing there about stream completion. I suppose it should
> complete normally. The name Cancellable threw me a bit. Most of the JavaDoc
> for the Graph variants associate cancellation with failure; for example:
> 'Cancels when' downstream cancels.
>
>
--
>>>>>>>>>> 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 http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
