Hi,
Im currently trying to implement a valve Graph to manage pause/resume. We
can control the behavior of the graph by using the MaterializeValue
trait ValveSwitch {
def open: Unit
def close: Unit
}
Current implementation of the valve
class Valve[A](mode: ValveMode = ValveMode.Open) exten
Please read this:
- http://blog.akka.io/integrations/2016/08/29/connecting-existing-apis
- and this:
http://doc.akka.io/docs/akka/2.4/scala/stream/stream-customize.html
Specifically, your trigger should be implemented as async-callback, as it
comes from the outside but should "wake up" the stage t
Thanks a lot for your informations (and sorry for the double post).
Can you please tell me what is the way to "wake up the stage", it is not
really obvious how to make that happen.
Thanks
Le vendredi 14 octobre 2016 04:09:12 UTC-4, Konrad Malawski a écrit :
>
> Please read this:
> - http://blog.
