pub struct PipeLine<'pl, E, C> {
pub marker: String,
pub rank: i16,
pub extensions: Extensions,
/* private fields */
}
Expand description
Represents a medium that manipulates the collected data structure of App
In practise, it processes the collected data and consume it
according to the marker
and rank
Fields
marker: String
rank: i16
extensions: Extensions
additional arguments for extensive application
Implementations
sourceimpl<'pl, E, C> PipeLine<'pl, E, C>
impl<'pl, E, C> PipeLine<'pl, E, C>
sourcepub fn builder() -> PipeLineBuilder<'pl, E, C>
pub fn builder() -> PipeLineBuilder<'pl, E, C>
Create an instance of PipeLinesBuilder
that used to build a PipeLine
Examples
async fn process_entity(&mut Vec<E>, &mut App<E>) {}
let pipeline = Pipeline::builder()
.process_entity(process_entity)
.build("marker");
sourcepub fn rank(&self) -> i16
pub fn rank(&self) -> i16
get the rank of PipeLine
Examples
async fn process_entity(&mut Vec<E>, &mut App<E>) {}
let pipeline = Pipeline::builder()
.process_entity(process_entity)
.build("marker");
assert_eq!(pipeline.rank(), 0);
sourcepub fn rank_mut(&mut self) -> &mut i16
pub fn rank_mut(&mut self) -> &mut i16
get mutable reference to rank of PipeLine
Examples
async fn process_entity(&mut Vec<E>, &mut App<E>) {}
let pipeline = Pipeline::builder()
.process_entity(process_entity)
.build("marker");
pipeline.rank_mut() = 3;
assert_eq!(pipeline.rank(), 3);
sourcepub fn extensions_mut(&mut self) -> &mut Extensions
pub fn extensions_mut(&mut self) -> &mut Extensions
mutate the extensions of PipeLine
Examples
let mut pipeline = Pipeline::builder()
.extensions(1i32)
.build("marker");
pipeline.extension_mut().insert(2i32);
sourcepub fn extensions(&self) -> &Extensions
pub fn extensions(&self) -> &Extensions
get extensions of PipeLine
Examples
let pipeline = Pipeline::builder()
.extensions(1i32)
.build("marker");
assert_eq!(pipeline.extensions().get::<i32>(), 1);
sourcepub fn initializer_mut(
self,
initials: &'pl dyn for<'a> Fn(&'a mut App<E>) -> BoxFuture<'a, Option<C>>
) -> Self
pub fn initializer_mut(
self,
initials: &'pl dyn for<'a> Fn(&'a mut App<E>) -> BoxFuture<'a, Option<C>>
) -> Self
Set the initializer
of PipeLine
, if not called, the default value is None
Examples
async fn initializer(_: &mut App<E>) {}
let pipeline = PipeLines::builder()
.initializer_mut(&initializer)
.build("marker".into());
assert! (pipeline.initializer.is_some())
sourcepub fn initializer(
&self
) -> Option<&'pl dyn for<'a> Fn(&'a mut App<E>) -> BoxFuture<'a, Option<C>>>
pub fn initializer(
&self
) -> Option<&'pl dyn for<'a> Fn(&'a mut App<E>) -> BoxFuture<'a, Option<C>>>
Get the shared reference of initializer
of PipeLine
, if not set before, None
is returned
Examples
async fn initializer(_: &mut App<E>) {}
let pipeline = PipeLines::builder()
.initializer_mut(&initializer)
.build("marker".into());
assert_eq! (pipeline.initializer (), Some(initializer))
sourcepub fn disposer_mut(
self,
dispose: &'pl dyn for<'a> Fn(&'a mut App<E>) -> BoxFuture<'a, ()>
) -> Self
pub fn disposer_mut(
self,
dispose: &'pl dyn for<'a> Fn(&'a mut App<E>) -> BoxFuture<'a, ()>
) -> Self
Set the disposer
of PipeLine
, if not called, the default value is None
Examples
async fn disposer(_: &mut App<E>) {}
let pipeline = PipeLines::builder()
.disposer_mut(&disposer)
.build("marker".into());
assert! (pipeline.disposer.is_some())
sourcepub fn disposer(
&self
) -> Option<&'pl dyn for<'a> Fn(&'a mut App<E>) -> BoxFuture<'a, ()>>
pub fn disposer(
&self
) -> Option<&'pl dyn for<'a> Fn(&'a mut App<E>) -> BoxFuture<'a, ()>>
Get the shared reference of disposer
of PipeLine
, if not set before, None
is returned
Examples
async fn disposer(_: &mut App<E>) {}
let pipeline = PipeLines::builder()
.disposer_mut(&disposer)
.build("marker".into());
assert_eq! (pipeline.disposer (), Some(disposer))
sourcepub fn entity_mut(
self,
entity: &'pl dyn for<'a> Fn(Vec<E>, &'a mut App<E>) -> BoxFuture<'a, ()>
) -> Self
pub fn entity_mut(
self,
entity: &'pl dyn for<'a> Fn(Vec<E>, &'a mut App<E>) -> BoxFuture<'a, ()>
) -> Self
Set the process_entity
of PipeLine
, if not called, the default value is None
Examples
async fn process_entity(_ : & mut Vec < E >,_: &mut App<E>) {}
let pipeline = PipeLines::builder()
.entity_mut(&process_entity)
.build("marker".into());
assert! (pipeline.process_entity.is_some())
sourcepub fn entity(
&self
) -> Option<&'pl dyn for<'a> Fn(Vec<E>, &'a mut App<E>) -> BoxFuture<'a, ()>>
pub fn entity(
&self
) -> Option<&'pl dyn for<'a> Fn(Vec<E>, &'a mut App<E>) -> BoxFuture<'a, ()>>
Get the shared reference of process_entity
of PipeLine
, if not set before, None
is returned
Examples
async fn process_entity(_ : & mut Vec < E >,_: &mut App<E>) {}
let pipeline = PipeLines::builder()
.entity_mut(&process_entity)
.build("marker".into());
assert_eq! (pipeline.entity (), Some(process_entity))
sourcepub fn yerr_mut(
self,
yerr: &'pl dyn for<'a> Fn(Vec<Result<Response, MetaResponse>>, &'a mut App<E>) -> BoxFuture<'a, ()>
) -> Self
pub fn yerr_mut(
self,
yerr: &'pl dyn for<'a> Fn(Vec<Result<Response, MetaResponse>>, &'a mut App<E>) -> BoxFuture<'a, ()>
) -> Self
Set the process_yerr
of PipeLine
, if not called, the default value is None
Examples
async fn process_yerr(_ : & mut Vec < Result<Response, MetaResponse> >,_: &mut App<E>) {}
let pipeline = PipeLines::builder()
.yerr_mut(&process_yerr)
.build("marker".into());
assert! (pipeline.process_yerr.is_some())
sourcepub fn yerr(
&self
) -> Option<&'pl dyn for<'a> Fn(Vec<Result<Response, MetaResponse>>, &'a mut App<E>) -> BoxFuture<'a, ()>>
pub fn yerr(
&self
) -> Option<&'pl dyn for<'a> Fn(Vec<Result<Response, MetaResponse>>, &'a mut App<E>) -> BoxFuture<'a, ()>>
Get the shared reference of process_yerr
of PipeLine
, if not set before, None
is returned
Examples
async fn process_yerr(_ : & mut Vec < Result<Response, MetaResponse> >,_: &mut App<E>) {}
let pipeline = PipeLines::builder()
.yerr_mut(&process_yerr)
.build("marker".into());
assert_eq! (pipeline.yerr (), Some(process_yerr))
Auto Trait Implementations
impl<'pl, E, C> !RefUnwindSafe for PipeLine<'pl, E, C>
impl<'pl, E, C> !Send for PipeLine<'pl, E, C>
impl<'pl, E, C> !Sync for PipeLine<'pl, E, C>
impl<'pl, E, C> Unpin for PipeLine<'pl, E, C>
impl<'pl, E, C> !UnwindSafe for PipeLine<'pl, E, C>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more