First bits of the implementation
WIP
Handling of EOS
Add the map operation
Send events in the stream and not plain values
Refactor the is_eos? method out of the stream class
Extract subscription handling and emitting into the Dispatcher class.
Add the log op and fix EOS propagation
Extract the dispatching block into a separate method, so that it'd be possible to override it in child classes