Struct Sandboxed

pub struct Sandboxed<T> {
    arena: Option<Arc<RwLock<SlotMap<NodeId, Box<dyn Any + Send + Sync>>>>>,
    inner: T,
}

A Future that restores its associated arena as the current arena whenever it is polled.

Sandboxed arenas are used to ensure that data created in response to e.g., different HTTP requests can be handled separately, while providing stable identifiers for their stored values. Wrapping a Future in Sandboxed ensures that it will always use the same arena that it was created under.

Fields

arena: Option<Arc<RwLock<SlotMap<NodeId, Box<dyn Any + Send + Sync>>>>>

inner: T

Implementations

impl<T> Sandboxed<T>

pub fn new(inner: T) -> Sandboxed<T>

Wraps the given Future, ensuring that any ArenaItem created while it is being polled will be associated with the same arena that was active when this was called.

Trait Implementations

impl<Fut> Future for Sandboxed<Fut>

where Fut: Future,

type Output = <Fut as Future>::Output

The type of value produced on completion.

fn poll( self: Pin<&mut Sandboxed<Fut>>, cx: &mut Context<'_>, ) -> Poll<<Sandboxed<Fut> as Future>::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl<T> Stream for Sandboxed<T>

where T: Stream,

type Item = <T as Stream>::Item

Values yielded by the stream.

fn poll_next( self: Pin<&mut Sandboxed<T>>, cx: &mut Context<'_>, ) -> Poll<Option<<Sandboxed<T> as Stream>::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<'__pin, T> Unpin for Sandboxed<T>

where <PinnedFieldsOfHelperStruct<__Origin<'__pin, T>> as PinnedFieldsOfHelperTrait>::Actual: Unpin,