class

Nucleoc::Injector(T)

A handle for adding items to a Nucleo worker.

Constructors

new(items : Boxcar(T), notify : -> Nil, release_callback : -> Nil, generation : Int32)

clear

Clear all items.

extend(values : Enumerable(T), &fill_columns : T, Array(Utf32String) -> Nil) : Nil

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

get(index : UInt32) : Item(T) | Nil

Returns a reference to the item at the given index.

injected_items

Returns the total number of items injected in the matcher.

push(value : T, &fill_columns : T, Array(Utf32String) -> Nil) : UInt32

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

release

Explicitly release this injector