Expand description
Library of generic operators for building ERDOS applications.
Structs
Merges the contents of two streams.
Filters an incoming stream of type D, retaining messages in the stream that the provided condition function evaluates to true when applied.
Maps an incoming stream of type D to a stream of type I::Item
using the provided
function.
Splits an incoming stream of type D1 into two different streams of type D1 using the provided condition function. When evaluated to true, sends messages to left stream, and right stream otherwise.
Joins messages with matching timestamps from two different streams.