Skip to content

Instantly share code, notes, and snippets.

@yeshvantbhavnasi
Created October 4, 2021 18:13
Show Gist options
  • Save yeshvantbhavnasi/da7086d31efee86dbde54b36b384e140 to your computer and use it in GitHub Desktop.
Save yeshvantbhavnasi/da7086d31efee86dbde54b36b384e140 to your computer and use it in GitHub Desktop.

AKKA Streams

Reactive Streams

  • Asynchronous
  • Backpressured
  • incremental
  • potentially infinite data processing systems

Publishers

Subscribers

Transformers

All data is send between above entities asynchronously with backpressures

Components of Akka

  • Source (Publishers)
  • Sink (Subscribers)
  • Flow (Processor)

We can created connected components

Directions

Upstream => To the source Downstream => To the sink

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment