Wikipedia

Reactive Streams

Reactive Streams is an initiative to provide a standard for asynchronous stream processing with non-blocking back pressure.[1][2]

Reactive Streams
Initial release15 May 2015; 9 years ago (2015-05-15)
Stable release
1.0.3 / 23 August 2019; 5 years ago (2019-08-23)
Repositorygithub.com/reactive-streams/reactive-streams-jvm
Written inJava (Scala, Groovy, Kotlin), .NET
Websitereactive-streams.org

Origin

edit

Reactive Streams started as an initiative in late 2013 between engineers at Netflix, Pivotal and Lightbend. Some of the earliest discussions began in 2013 between the Play and Akka teams at Lightbend.[3][4] Lightbend is one of the main contributors of Reactive Streams.[5] Other contributors include Red Hat, Oracle, Twitter and spray.io.[6]

Goals

edit

The main goal of Reactive Streams is to govern the exchange of stream data across an asynchronous boundary – like passing elements on to another thread or thread-pool – while ensuring that the receiving side is not forced to buffer arbitrary amounts of data. In other words, back pressure is an integral part of this model in order to allow the queues which mediate between threads to be bounded.

The intention of the specification is to allow the creation of many conforming implementations, which by virtue of abiding by the rules will be able to interoperate smoothly, preserving the mentioned benefits and characteristics across the whole processing graph of a stream application. A freely-available Technology Compatibility Kit[7] was developed alongside the specification that allows implementors of the specification to verify if they covered all rules and requirements, including checks for potential race conditions.

The scope of Reactive Streams is a minimal set of interfaces, methods and protocols that describe the necessary operations and entities to achieve the asynchronous streams of data with non-blocking back pressure.[2] End-user DSLs or protocol binding APIs have purposefully been left out of the scope to encourage and enable different implementations that potentially use different programming languages to stay as true as possible to the idioms of their platform.

Inclusion in Java standard

edit

The specification developed with the intent of future inclusion in the official Java standard library, if proven successful and adopted by enough libraries and vendors.

Reactive Streams were proposed to become part of Java 9 by Doug Lea, leader of JSR 166[8] as a new Flow class[9] that would include the interfaces currently provided by Reactive Streams.[5][10] After a successful 1.0 release of Reactive Streams and growing adoption, the proposal was accepted and Reactive Streams was included in JDK9 via the JEP-266.[10]

Adoption

edit

On April 30, 2015 version 1.0.0 of Reactive Streams for the JVM was released,[5][6][11] including Java API,[12] a textual specification,[13] a TCK and implementation examples. It comes with a multitude of compliant implementations verified by the TCK for 1.0.0, listed in alphabetical order:[11]

Other implementations include Cassandra,[23] Elasticsearch,[24] Apache Kafka,[25] Parallel Universe Quasar,[26] Play Framework,[27] Armeria.[28]

Spring 5 is announced to be built upon Reactive Streams compatible Reactor Core.[29]

Amazon announced that its Amazon Web Services SDK would support Reactive Streams to provide streaming capabilities in its client libraries in version 2.0.[30]

Reactive Streams 1.0.1 is released on August 9, 2017, including various improvements in specification preciseness, TCK improvements and other clarifications. The specification as well as interfaces remained fully backwards compatible with the 1.0.0 version, however aimed to streamline the adoption for future implementors as well as align with some additional requirements set by the OpenJDK.[31]

Ports and influences

edit
  • A direct port of the specification, interfaces and TCK was made available under the same working group for the .NET platform.[32]
  • When the Elixir language introduced its streaming API called GenStage, the authors extended a thanks "[to] akka-streams and reactive-streams projects which provided us guidance in implementing the demand-driven exchange between stages".[33]

Citations

edit
  1. ^ reactive-streams.org
  2. ^ a b c Walls 2019, pp. 243–245, §10.1.1 Defining Reactive Streams.
  3. ^ A Journey into Reactive Streams
  4. ^ Reactive Streams 1.0.0 interview
  5. ^ a b c Reactive Streams Releases First Stable Version for JVM
  6. ^ a b Reactive Streams 1.0.0 – a new standard in reactive data processing
  7. ^ "Reactive Streams TCK". GitHub.
  8. ^ "jdk9 Candidate classes Flow and SubmissionPublisher". Archived from the original on 2015-01-20. Retrieved 2015-12-23.
  9. ^ "java.util.concurrent.Flow". Archived from the original on 2016-02-03. Retrieved 2015-12-23.
  10. ^ a b JEP 266: More Concurrency Updates
  11. ^ a b Reactive Streams 1.0.0 is here!
  12. ^ Java API
  13. ^ Reactive Streams for the JVM specification
  14. ^ InfoQ: Reactive Streams with Akka Streams
  15. ^ "Design Principles behind Akka Streams". Archived from the original on 2016-01-12. Retrieved 2015-12-23.
  16. ^ MongoDB Reactive Streams Java Driver
  17. ^ Ratpack: The Reactive Streams API
  18. ^ Reactor 2.0.0.RC1 with native Reactive Streams support now available!
  19. ^ Advanced RxJava: The Reactive-Streams API (part 1)
  20. ^ Slick 3: Reactive Streams for Asynchronous Database Access in Scala
  21. ^ Slick 3.0.0
  22. ^ Vert.x Reactive Streams Integration
  23. ^ Accessing Cassandra in a Reactive Way
  24. ^ elastic4s — Non blocking, type safe DSL and Scala client for Elasticsearch
  25. ^ Reactive Streams for Apache Kafka
  26. ^ "Quasar and Reactive Streams". Archived from the original on 2015-10-04. Retrieved 2015-12-24.
  27. ^ Play Framework — Reactive Streams integration (experimental)
  28. ^ Armeria - Completely asynchronous and reactive
  29. ^ Reactive Spring
  30. ^ "AWS SDK for Java 2.0 developer preview announcement".
  31. ^ "Reactive Streams 1.0.1 Release Announcement".
  32. ^ "Reactive Streams .NET". GitHub.
  33. ^ "Elixir blog: Announcing GenStage".

References

edit
  •   This article incorporates text from www.reactive-streams.org, which is released under a CC0 1.0 Universal (CC0 1.0) Public Domain Dedication.
Retrieved from "https://en.wikipedia.org/w/index.php?title=Reactive_Streams&oldid=1158911584"