pub fn pipe<E, F>(reader: E, f: F) -> PipeHandle where
E: IntoReader,
F: 'static + Send + FnMut(E::Output), Expand description
Produce a side effect with the latest snapshots as they become available. The caller must not drop the returned PipeHandle until it is no longer desirable to produce the side effect.