A minimal CES framework

Before we get start on the details, we should define at a high level what minimal means.

Let's start with the two main abstractions our framework will provide: behaviors and event streams.

If you can recall from Chapter 1, What is Reactive Programming?, behaviors represent continuous, time-varying values such as time or a mouse position behavior. Event streams, on the other hand, represent discrete occurrences at a point in time T, such as key press.

Next, we should think about what kinds of operations we would like to support. Behaviors are fairly simple so at the very minimum we need to:

• Create new behaviors
• Retrieve the current value of a behavior
• Convert a behavior into an event stream

Event streams have more interesting logic in play and we should at least support these operations:

• Push/deliver a value down the stream
• Create a stream from a given interval
• Transform the stream with the map and filter operations
• Combine streams with flatmap
• Subscribe to a stream

This...