Struct StreamProcessor 

pub struct StreamProcessor { /* private fields */ }

Stream processor for handling attention in chunks

Implementations

impl StreamProcessor

pub fn instance_of<V: NapiRaw>(env: Env, value: V) -> Result<bool>

impl StreamProcessor

pub fn into_reference( val: StreamProcessor, env: Env, ) -> Result<Reference<StreamProcessor>>

pub fn into_instance(self, env: Env) -> Result<ClassInstance<StreamProcessor>>

impl StreamProcessor

pub fn new(dim: u32, max_buffer_size: u32) -> Self

Create a new stream processor

Arguments

• dim - Embedding dimension
• max_buffer_size - Maximum number of items to buffer

pub fn push(&mut self, vector: Float32Array) -> bool

Add a vector to the buffer

pub fn process(&self, query: Float32Array) -> Result<Float32Array>

Process buffered vectors with attention against a query

pub fn clear(&mut self)

Clear the buffer

pub fn size(&self) -> u32

Get current buffer size

pub fn is_full(&self) -> bool

Check if buffer is full

Trait Implementations

impl FromNapiMutRef for StreamProcessor

unsafe fn from_napi_mut_ref( env: napi_env, napi_val: napi_value, ) -> Result<&'static mut Self>

Safety

impl FromNapiRef for StreamProcessor

unsafe fn from_napi_ref( env: napi_env, napi_val: napi_value, ) -> Result<&'static Self>

Safety

impl FromNapiValue for &StreamProcessor

unsafe fn from_napi_value(env: napi_env, napi_val: napi_value) -> Result<Self>

Safety

fn from_unknown(value: JsUnknown) -> Result<Self, Error>

impl FromNapiValue for &mut StreamProcessor

unsafe fn from_napi_value(env: napi_env, napi_val: napi_value) -> Result<Self>

Safety

fn from_unknown(value: JsUnknown) -> Result<Self, Error>

impl ObjectFinalize for StreamProcessor

fn finalize(self, env: Env) -> Result<(), Error>

impl ToNapiValue for StreamProcessor

unsafe fn to_napi_value( env: napi_env, val: StreamProcessor, ) -> Result<napi_value>

Safety

impl TypeName for &StreamProcessor

fn type_name() -> &'static str

fn value_type() -> ValueType

impl TypeName for &mut StreamProcessor

fn type_name() -> &'static str

fn value_type() -> ValueType

impl TypeName for StreamProcessor

fn type_name() -> &'static str

fn value_type() -> ValueType

impl ValidateNapiValue for &StreamProcessor

unsafe fn validate(env: napi_env, napi_val: napi_value) -> Result<napi_value>

Safety

impl ValidateNapiValue for &mut StreamProcessor

unsafe fn validate(env: napi_env, napi_val: napi_value) -> Result<napi_value>

Safety