Struct device_connector::base::RepeatProcessSrcElement

pub struct RepeatProcessSrcElement { /* private fields */ }

Captures process stdout.

Trait Implementations

impl ElementBuildable for RepeatProcessSrcElement

type Config = RepeatProcessSrcElementConf

Configuration type for this element

const NAME: &'static str = "repeat-process-src"

Name of this element. Must be unique in elements

const SEND_PORTS: Port = 1u8

The number of sending ports

fn new(conf: Self::Config) -> Result<Self, Error>

Create element from config

fn next(
    &mut self,
    pipeline: &mut Pipeline,
    _receiver: &mut MsgReceiver
) -> ElementResult

Get message from receiver and returns the result of this element.

const RECV_PORTS: Port = 0u8

The number of receiving ports

fn acceptable_msg_types() -> Vec<Vec<MsgType>>

Returns acceptable message type of this element

fn finalizer(&mut self) -> Result<Option<ElementFinalizer>, Error>

Returns the finalizer of this element