Struct Context

pub struct Context<T: Data> { /* private fields */ }

Implementations

impl<T: Send + Sync + 'static> Context<T>

pub fn new(current: T) -> Self

pub fn with_controller(current: T, controller: Controller) -> Self

pub fn with_id(current: T, id: String) -> Self

pub fn id(&self) -> &str

pub fn controller(&self) -> &Controller

pub fn insert<K: ToString, U: Send + Sync + 'static>( &mut self, key: K, value: U, )

Insert an object into the registry with a specific key.

pub fn insert_unique<K: ToString, U: Send + Sync + 'static>( &mut self, key: K, value: U, )

Insert a unique and takable object into the registry with a specific key.

pub fn get<V: Send + Sync + 'static>(&self, key: &str) -> Result<Arc<V>, String>

Retrieve an object from the registry by key and type.

pub fn clone_unique<V: Clone + Send + Sync + 'static>( &self, key: &str, ) -> Result<V, String>

Clone a unique object from the registry by key and type.

pub fn take_unique<V: Send + Sync + 'static>( &mut self, key: &str, ) -> Result<V, String>

Take a unique object from the registry by key and type.

pub fn transfer<U: Send + Sync + 'static>( self, new_current: U, ) -> (T, Context<U>)

Transfer the Context to a new Object without updating the registry This returns a tuple of the previous object and the new Context

pub fn into_parts(self) -> (T, Context<()>)

Separate out the current object and context

pub fn stages(&self) -> &Vec<String>

pub fn add_stage(&mut self, stage: &str)

pub fn map<U: Send + Sync + 'static, F>(self, f: F) -> Context<U>

where F: FnOnce(T) -> U,

Transforms the current context to another type using a provided function.

pub fn try_map<U, F, E>(self, f: F) -> Result<Context<U>, E>

where F: FnOnce(T) -> Result<U, E>, U: Send + Sync + 'static,

Trait Implementations

impl<T, U> AsyncEngine<Context<AddressedRequest<T>>, Pin<Box<dyn AsyncEngineStream<U, Item = U>>>, Error> for AddressedPushRouter

where T: Data + Serialize, U: Data + for<'de> Deserialize<'de>,

fn generate<'life0, 'async_trait>( &'life0 self, request: SingleIn<AddressedRequest<T>>, ) -> Pin<Box<dyn Future<Output = Result<ManyOut<U>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Generate a stream of completion responses.

impl<T, U> AsyncEngine<Context<T>, Pin<Box<dyn AsyncEngineStream<U, Item = U>>>, Error> for Egress<SingleIn<T>, ManyOut<U>>

where T: Data + Serialize, U: for<'de> Deserialize<'de> + Data,

fn generate<'life0, 'async_trait>( &'life0 self, request: SingleIn<T>, ) -> Pin<Box<dyn Future<Output = Result<ManyOut<U>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Generate a stream of completion responses.

impl<T, U> AsyncEngine<Context<T>, Pin<Box<dyn AsyncEngineStream<U, Item = U>>>, Error> for PushRouter<T, U>

where T: Data + Serialize, U: Data + for<'de> Deserialize<'de>,

fn generate<'life0, 'async_trait>( &'life0 self, request: SingleIn<T>, ) -> Pin<Box<dyn Future<Output = Result<ManyOut<U>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Generate a stream of completion responses.

impl<T: Data> AsyncEngineContextProvider for Context<T>

fn context(&self) -> Arc<dyn AsyncEngineContext>

impl<T: Data> Debug for Context<T>

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

Formats the value using the given formatter.

impl<T: Data> Deref for Context<T>

type Target = T

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<T: Data> DerefMut for Context<T>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl<T: Send + Sync + 'static> From<Context<T>> for StreamContext

fn from(value: Context<T>) -> Self

Converts to this type from the input type.

impl<T> From<T> for Context<T>

where T: Send + Sync + 'static,

fn from(current: T) -> Self

Converts to this type from the input type.

impl<T, U> IntoContext<U> for Context<T>

where T: Send + Sync + 'static + Into<U>, U: Send + Sync + 'static,

fn into_context(self) -> Context<U>

impl<T: Data> PipelineIO for Context<T>

fn id(&self) -> String