Struct dyer::plugin::pipeline::PipeLine [−][src]
pub struct PipeLine<'pl, E, C> {
pub marker: String,
pub rank: i16,
pub extensions: Extensions,
// some fields omitted
}
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
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".into());
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".into());
assert_eq!(pipeline.rank(), 0);
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".into());
pipeline.rank_mut() = 3;
assert_eq!(pipeline.rank(), 3);
mutate the extensions of PipeLine
Examples
let mut pipeline = Pipeline::builder()
.extensions(1i32)
.build("marker".into());
pipeline.extension_mut().insert(2i32);
get extensions of PipeLine
Examples
let pipeline = Pipeline::builder()
.extensions(1i32)
.build("marker".into());
assert_eq!(pipeline.extensions().get::<i32>(), 1);
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())
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))
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())
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))
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())
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))
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())
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> !UnwindSafe for PipeLine<'pl, E, C>
Blanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more