search

manuzhang / read-it-now

Don't read it later; read it now
4 stars 0 forks source link

Akka Stream Patterns #6

Open manuzhang opened 7 years ago

manuzhang commented 7 years ago

Article

Notes

pattern operation note
flatten mapConcat requires immutable collection
merge in sequence flatMapConcat
merge simultaneously flatMapMerge order of the substreams is not guaranteed
batching in number grouped
batching in time groupedWithin
asynchronous computation mapAsync / mapAsyncUnordered with back pressure
concurrent computation async
termination onComplete / watchForTermination
rate limit throttle with back pressure
idle timeouts idleTimeout
failing stage recovery Supervision.stopDecider / resumingDecider / restartingDecider defined in ActorMaterializer
restarting pipeline recoverWithRetries