Thanks a lot!!
On Tuesday, 25 April 2017 18:39:58 UTC+7, Akka Team wrote:
>
> Partition allows you to look at a message and decide which of its outlets
> to pass the element to, this way you can design the logic of each sub
> stream independently. Something like this:
>
> val flow: Flow[Int,
Partition allows you to look at a message and decide which of its outlets
to pass the element to, this way you can design the logic of each sub
stream independently. Something like this:
val flow: Flow[Int, Int, NotUsed] = Flow.fromGraph(GraphDSL.create() {
implicit builder =>
import
Hello all,
I have defined my application flow like this,
*val flow = Flow[StringConsumerRecord].*
* map(tup => new Ticket(tup.value.toLong)).*
* mapConcat(applyBusinessLogic(_)).*
* groupBy(4, _._1).*
* groupedWithin(100, 5.second).*
* mergeSubstreams.*
* throttle(1, 1.second, 1,
