Struct async_map_reduce::managers::ReduceManager
source · [−]pub struct ReduceManager<'a, Ctx, Req, Resp: Sss, MF: Fn(&Ctx, usize, &Req) -> Resp, RF: Fn(&Ctx, Resp, Resp) -> Resp> { /* private fields */ }Implementations
sourceimpl<'a, Ctx: 'static, Req: 'static, Resp: Sss, MF: SCFunMF<Ctx, Req, Resp>, RF: 'static + Fn(&Ctx, Resp, Resp) -> Resp> ReduceManager<'a, Ctx, Req, Resp, MF, RF>
impl<'a, Ctx: 'static, Req: 'static, Resp: Sss, MF: SCFunMF<Ctx, Req, Resp>, RF: 'static + Fn(&Ctx, Resp, Resp) -> Resp> ReduceManager<'a, Ctx, Req, Resp, MF, RF>
pub fn default(
self,
default_value: Resp
) -> FullManager<'a, Ctx, Req, Resp, MF, RF>
sourceimpl<'a, Ctx: 'static, Req: 'static, Resp: Sss + Default, MF: SCFunMF<Ctx, Req, Resp>, RF: 'static + Fn(&Ctx, Resp, Resp) -> Resp> ReduceManager<'a, Ctx, Req, Resp, MF, RF>
impl<'a, Ctx: 'static, Req: 'static, Resp: Sss + Default, MF: SCFunMF<Ctx, Req, Resp>, RF: 'static + Fn(&Ctx, Resp, Resp) -> Resp> ReduceManager<'a, Ctx, Req, Resp, MF, RF>
pub fn run(self, chunks: &[Req]) -> Result<Resp, ThreadError>
sourceimpl<'a, Ctx: 'static, Req: 'static, ROk: Sss + Default, RErr: Sss, MF: SCFunMF<Ctx, Req, Result<ROk, RErr>>, RF: 'static + Fn(&Ctx, Result<ROk, RErr>, Result<ROk, RErr>) -> Result<ROk, RErr>> ReduceManager<'a, Ctx, Req, Result<ROk, RErr>, MF, RF>
impl<'a, Ctx: 'static, Req: 'static, ROk: Sss + Default, RErr: Sss, MF: SCFunMF<Ctx, Req, Result<ROk, RErr>>, RF: 'static + Fn(&Ctx, Result<ROk, RErr>, Result<ROk, RErr>) -> Result<ROk, RErr>> ReduceManager<'a, Ctx, Req, Result<ROk, RErr>, MF, RF>
pub fn run_result(self, chunks: &[Req]) -> Result<ROk, MapReduceError<RErr>>
Auto Trait Implementations
impl<'a, Ctx, Req, Resp, MF, RF> RefUnwindSafe for ReduceManager<'a, Ctx, Req, Resp, MF, RF> where
Ctx: RefUnwindSafe,
MF: RefUnwindSafe,
RF: RefUnwindSafe,
Req: RefUnwindSafe,
impl<'a, Ctx, Req, Resp, MF, RF> Send for ReduceManager<'a, Ctx, Req, Resp, MF, RF> where
Ctx: Sync,
MF: Send,
RF: Send,
Req: Send,
impl<'a, Ctx, Req, Resp, MF, RF> Sync for ReduceManager<'a, Ctx, Req, Resp, MF, RF> where
Ctx: Sync,
MF: Sync,
RF: Sync,
Req: Sync,
impl<'a, Ctx, Req, Resp, MF, RF> Unpin for ReduceManager<'a, Ctx, Req, Resp, MF, RF> where
MF: Unpin,
RF: Unpin,
Req: Unpin,
impl<'a, Ctx, Req, Resp, MF, RF> UnwindSafe for ReduceManager<'a, Ctx, Req, Resp, MF, RF> where
Ctx: RefUnwindSafe,
MF: UnwindSafe,
RF: UnwindSafe,
Req: UnwindSafe,
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcepub fn borrow_mut(&mut self) -> &mut T
pub fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more