Struct chewdata::step::reader::Reader

pub struct Reader {
    pub connector_type: ConnectorType,
    pub document_type: DocumentType,
    pub name: String,
    pub description: Option<String>,
    pub data_type: String,
    pub wait: u64,
    pub receiver: Option<Receiver<StepContext>>,
    pub sender: Option<Sender<StepContext>>,
}

Fields

connector_type: ConnectorType

document_type: DocumentType

name: String

description: Option<String>

data_type: String

wait: u64

receiver: Option<Receiver<StepContext>>

sender: Option<Sender<StepContext>>

Trait Implementations

impl Clone for Reader

fn clone(&self) -> Reader

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Reader

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

Formats the value using the given formatter.

impl Default for Reader

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Reader where
    Reader: Default, 

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl Display for Reader

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

Formats the value using the given formatter.

impl Step for Reader

fn set_receiver(&mut self, receiver: Receiver<StepContext>)

See Step::set_receiver for more details.

fn receiver(&self) -> Option<&Receiver<StepContext>>

See Step::receiver for more details.

fn set_sender(&mut self, sender: Sender<StepContext>)

See Step::set_sender for more details.

fn sender(&self) -> Option<&Sender<StepContext>>

See Step::sender for more details.

fn sleep(&self) -> u64

See Step::sleep for more details.

fn exec<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn name(&self) -> String

fn thread_number(&self) -> usize