Struct Immediate 

pub struct Immediate<S>(pub S);

Presents a synchronous ObjectSource as an AsyncObjectSource whose futures are already complete.

Wrapping a source in Immediate is what lets the synchronous entry points share the asynchronous implementation. Because every future this produces is std::future::Ready, a future tree built over it completes on its first poll and never parks — see block_on.

Note the divergence from a genuinely asynchronous source: these futures do their work eagerly, when the method is called, rather than lazily on first poll. Constructing one and dropping it unpolled still performs the read. That is invisible to an algorithm that awaits what it constructs, but it means Immediate is not a timing-faithful stand-in for a streaming source.

Tuple Fields

0: S

Trait Implementations

impl<S: ObjectSource> AsyncObjectSource for Immediate<S>

fn get(&self, r: ObjRef) -> BoxFuture<'_, Result<Object>>

Fetches an indirect object by reference.

fn stream_data<'a>(&'a self, s: &'a Stream) -> BoxFuture<'a, Result<Vec<u8>>>

Decodes a stream’s data through its filter chain, resolving indirect filter parameters against this source.

fn resolve<'a>(&'a self, o: &'a Object) -> BoxFuture<'a, Result<Object>>

Chases reference chains, depth-capped at MAX_RESOLVE_DEPTH.

impl<S: Clone> Clone for Immediate<S>

fn clone(&self) -> Immediate<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Copy> Copy for Immediate<S>

impl<S: Debug> Debug for Immediate<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.