Module expiration_map

Structs

• Emitter

Functions

• map_with_expiration
  Similar to stream.filter_map(..).flatten(..) but also allows checking for expired events and flushing when the input stream ends.