Skip to main content

Get

Trait Get 

Source
pub trait Get<'a, K, S>
where Self: Sized, S: Stream<Item = K> + Send + 'a, K: AsRef<[u8]> + Send + Sync + 'a,
{ // Required method fn get( self, map: &'a Arc<Map>, ) -> impl Stream<Item = Result<Handle<'_>>> + Send + 'a; }
Expand description

Extends a stream of raw keys with batched map lookup.

Input keys are grouped for the engine’s blocking pool. The output stream yields pinned value handles or lookup errors.

Required Methods§

Source

fn get( self, map: &'a Arc<Map>, ) -> impl Stream<Item = Result<Handle<'_>>> + Send + 'a

Fetches this stream’s raw keys from a map.

Successful batches yield one lookup result for each input key. A batch-level pool or channel failure appears as one stream error for that batch. Work is split into batches sized from the server’s automatic amplification setting.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§

Source§

impl<'a, K, S> Get<'a, K, S> for S
where Self: Sized, S: Stream<Item = K> + Send + 'a, K: AsRef<[u8]> + Send + Sync + 'a,