https://softwarepatternslexicon.com/ruby/reactive-programming-patterns/asynchronous-data-streams/