vector_stream

Module expiration_map

Source

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.