Transform and filter operations on streams

Authored by ivan on May 8 2018, 5:26 PM.

Description

Transform and filter operations on streams

Implemented the most important stream operations:

  • filter: if a value does not satisfy a predicate, it is not sent to the next node
  • transform: for each received value, apply a transformation function and send the result to the next node instead of the original value

Details

Committed
ivanMay 7 2018, 9:56 PM
Parents
R610:97a18563690f: Created a source stream which emits values after a predefined delay
Branches
Unknown
Tags
Unknown