pub fn epoch_provide(
input: impl MessageStream,
) -> impl Stream<Item = Result<Message, StreamExecutorError>>Expand description
Streams wrapped by epoch_provide is able to retrieve the current epoch pair from the functions
from [epoch::task_local].