Structs§
Functions§
- map_
with_ expiration - Similar to
stream.filter_map(..).flatten(..)but also allows checking for expired events and flushing when the input stream ends.
stream.filter_map(..).flatten(..) but also allows checking for expired events
and flushing when the input stream ends.