Struct NonFiniteCounter 

pub struct NonFiniteCounter(/* private fields */);

A per-run count of non-finite values rendered as null.

Pipeline::run installs one around the run; record_non_finite counts into the innermost installed counter. A connector that converts values on a task or thread of its own carries the counter there with NonFiniteCounter::current and NonFiniteCounter::scope / NonFiniteCounter::scope_sync.

Implementations

impl NonFiniteCounter

pub fn new() -> Self

A counter at zero.

pub fn count(&self) -> u64

Values counted so far.

pub fn current() -> Option<Self>

The counter installed around the current task, if any.

pub fn scope<F: Future>(&self, fut: F) -> impl Future<Output = F::Output>

Run fut with this counter installed.

pub fn scope_sync<R>(&self, f: impl FnOnce() -> R) -> R

Run f (on a blocking thread, say) with this counter installed.

Trait Implementations

impl Clone for NonFiniteCounter

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for NonFiniteCounter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for NonFiniteCounter

fn default() -> Self

Returns the “default value” for a type.