Pipes and Filters

Based On Reactive Messaging Patterns with the Actor Model: Applications and Integration in Scala and Akka

Demo

https://github.com/PawelWlodarski/workshops-reactive/blob/master/src/main/scala/jug/workshops/reactive/patterns/pipesandfilters/exercises/PipeStandardDemo.scala

• How to chain actors together into one pipeline
• How to invoke next actor in the pipeline

Exercises

Standard Actors

EXERCISE FILE : https://github.com/PawelWlodarski/workshops-reactive/blob/master/src/main/scala/jug/workshops/reactive/patterns/pipesandfilters/exercises/PipeStandardExercise.scala

Implement Actors Bodies and use test to check correctness :

https://github.com/PawelWlodarski/workshops-reactive/blob/master/src/test/scala/jug/workshops/reactive/patterns/pipesandfilters/exercises/PipeStandardExercisesTest.scala

Akka Stream - in progress

"Work in my IDE example" in file : https://github.com/PawelWlodarski/workshops-reactive/blob/master/src/main/scala/jug/workshops/reactive/patterns/pipesandfilters/answers/PipesStreamsAnswer1.scala

Typed Actors - in progress