dyer 3.3.2

dyer is designed for reliable, flexible and fast Request-Response based service, including data processing, web-crawling and so on, providing some friendly, flexible, comprehensive features without compromising speed.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

//! Stands for a project, Set up initial condition and necessary component to start the workflow
//!
use crate::component::Task;
use crate::engine::App;
use crate::plugin::Affixor;
use async_trait::async_trait;
use std::error::Error;

/// Although it starts a project, the work to do here is not very complicated
/// it is as simple as setting up initial condition and other basic things.
///
/// Right here, if entry_affix returns None, then [Affix] is disabled
///
/// [Affix]: crate::component::affix::Affix
#[async_trait]
pub trait Actor<E, A>
where
    A: Affixor + Send + 'static,
{
    /// create a instance
    async fn new() -> Self
    where
        Self: Sized;

    /// implementation [Affixor] happens here
    /// when None is returned actor will disable affix customization
    async fn entry_affix(&mut self) -> Option<A>;

    /// method to generate [Task] when open [Actor]
    async fn entry_task(&mut self) -> Result<Vec<Task>, Box<dyn Error>>;

    /// preparation before enter [Actor]
    async fn open_actor(&mut self, app: &mut App<E>);

    /// preparation before close [Actor]
    async fn close_actor(&mut self, app: &mut App<E>);
}