Struct Injector 

pub struct Injector<T> { /* private fields */ }

A handle that allows adding new items to a Nucleo worker.

It’s internally reference counted and can be cheaply cloned and sent across threads.

Implementations

impl<T> Injector<T>

pub fn push( &self, value: T, fill_columns: impl FnOnce(&T, &mut [Utf32String]), ) -> u32

Appends an element to the list of matched items. This function is lock-free and wait-free.

pub fn extend<I>( &self, values: I, fill_columns: impl Fn(&T, &mut [Utf32String]), )

where I: IntoIterator<Item = T> + ExactSizeIterator,

Appends multiple elements to the list of matched items. This function is lock-free and wait-free.

You should favor this function over push if at least one of the following is true:

• the number of items you’re adding can be computed beforehand and is typically larger than 1k
• you’re able to batch incoming items
• you’re adding items from multiple threads concurrently (this function results in less contention)

pub fn injected_items(&self) -> u32

Returns the total number of items injected in the matcher. This might not match the number of items in the match snapshot (if the matcher is still running)

pub unsafe fn get_unchecked(&self, index: u32) -> Item<'_, T>

Returns a reference to the item at the given index.

Safety

Item at index must be initialized. That means you must have observed push returning this value or get returning Some for this value. Just because a later index is initialized doesn’t mean that this index is initialized

pub fn get(&self, index: u32) -> Option<Item<'_, T>>

Returns a reference to the element at the given index.

Trait Implementations

impl<T> Clone for Injector<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.