My fs2 (was scalaz-stream) User Notes
  • Introduction
  • Foundations
  • Design Patterns
    • Category Theory Express Design Patterns
    • Category Theory
      • Semigroup
      • Monoid
      • Functor
      • Applicative
      • Products\/Coproducts
      • Monad
      • Free Monad
    • Category Theory for fs2
  • fs2 Core Model
    • Streams and Graphs
    • Composability
    • API
    • Effects
      • fs2 Effects
    • Smart Constructors and Combinators
  • fs2 Basics
    • Technical Setup
    • Simple Streams
    • Effectful Streams
    • Error Handling and Resource Management
    • Sinks
    • Channels and Exchanges
    • Combining Streams: Wye and Tee
    • Refs
  • Cookbook
    • Recipe: onFinish for Task
    • Recipe: Changing Seq[A] to A
    • Recipe: Debugging with toString
    • Recipe: Retrieving Web Pages
    • Recipe: Converting an Iterator to a Stream
    • Recipe: Data-Driven Stream
    • Recipe: Evaluate a Task Periodically
    • Recipe: Delay running a stream
    • Recipe: Stop an infinite Stream when you want to
    • Recipe: CSV Parsing with univocity
    • Recipe: CSV Parsing with node.js csv-parse using Readable => Stream
  • fs2 Examples
    • Akka Examples
    • Cafe
    • More Than One Stream
Powered by GitBook
On this page

Was this helpful?

Introduction

NextFoundations

Last updated 5 years ago

Was this helpful?

THESE NOTES WILL BE UPDATED TO REFLECT FS2 1.x in 2019...HAD WAITED UNTIL THE API SETTLED DOWN

Reactive streams are computations organized to act on an infinite stream of data elements with bounded resource management. Most streaming libraries reflect the principles found in the . Reactive streams are designed to increase concurrency, manage back-pressure and improve expressiveness through composition.

There are many reactive streaming solutions including:

  • (cluster enabled)

There are also solutions that run on clusters. Cluster-based libraries have different approaches to distributing computations. Cluster-based libraries include:

This book contains notes for using fs2, formerly called scalaz-stream. These notes focus on practical uses of fs2 versus fs2's implementation details.

Note that fs2 is being rewritten from scalaz-stream and these notes have not been fully converte over yet. fs2 will not have dependencies on scalaz-stream or scalaz.

reactive streams manifesto
akka
scalaz-stream
haskell misc
spark
storm
scalding