akka / alpakka

Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
https://doc.akka.io/docs/alpakka/current/
Other
1.27k stars 647 forks source link

Caffeine Flow #34

Open cheleb opened 7 years ago

cheleb commented 7 years ago

Hi I can provide a Caffeine flow. Caffeine is a Cache librairie, I use to reconcile events, in memory.

Say event A, B, C

Let A(1), A(2), A(3), ...., B(1), C(1) event to enter the flow, this flow will emit (A(1), B(1), C(1)) on reconciled OutLet and (A(2), A(3)) on Expired OutLet

Any interest out there ?

patriknw commented 7 years ago

sounds cool, please go ahead