pub fn repeat<T: 'static>(
factory: impl Fn() -> Node<T> + 'static,
count: usize,
) -> Operator<T>Expand description
repeat: run a fresh source from factory count times in sequence.
The factory must return a fresh node for each round. Reusing the same node is not a repeat in the clean-slate substrate: same-boundary unsubscribe_dep+subscribe_dep is a no-op under D47. D115 keeps the model to ordinary unsubscribe plus a later subscribe, so same-node repeat needs a separate future design.