Trait Qry 

pub trait Qry<'a, K, S>
where
    S: Stream<Item = K> + Send + 'a,
    K: Serialize + Debug,
{
    // Required method
    fn qry(
        self,
        map: &'a Arc<Map>,
    ) -> impl Stream<Item = Result<Handle<'_>>> + Send + 'a;
}

Extends a stream of structured keys with serialized batched lookup.

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

Required Methods

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

Fetches this stream’s serialized keys from a map.

The returned stream yields lookup results from automatically sized batches. Serialization is deferred until the stream is polled.

Panics

Panics if an input key cannot be serialized.

Dyn Compatibility

This trait is not dyn compatible.

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

Implementors

impl<'a, K, S> Qry<'a, K, S> for S

where Self: 'a, S: Stream<Item = K> + Send + 'a, K: Serialize + Debug + 'a,