Inspired by Jonas Bonér's *Reactive Microservices Architecture* but for Akka Streams with Kafka, Avro, Cassandra, Akka HTTP, Algebird, & Actors with Typesafe Config and Logging.
Custom stream stages post-process calls that return errors or throw exceptions, some use Akka Streams Supervision. Queueing stages use backpressure to push a specified number of elements. Akka Streams built-in stages are a nice use of partially applied functions and currying: apply some arguments while initializing streams, apply another as a stage input. Users can start with examples and substitute their code and configurations. They can also use stream stages as templates for their custom ones. This began as a scratchpad for learning these technologies. To my surprise, Akka and Scala kept me free to experiment and change directions without painting myself into a corner. It also kept me free to blur the line between generic and custom where more could be generic but almost all of it is easily replaced. Documentation: https://garyaiki.github.io/dendrites/ Readme setup and code https://github.com/garyaiki/dendrites -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
