Struct sea_streamer_stdio::StdioConnectOptions

pub struct StdioConnectOptions { /* private fields */ }

Implementations

impl StdioConnectOptions

pub fn loopback(&self) -> bool

pub fn set_loopback(&mut self, b: bool)

If set to true, messages produced will be feed back to consumers in the same process.

Be careful, if your stream processor consume and produce the same stream key, it will result in an infinite loop.

This option is meant for testing only. Enabling loopback might create overhead where the producer and consumer threads compete for the same Mutex.

Trait Implementations

impl Clone for StdioConnectOptions

fn clone(&self) -> StdioConnectOptions

Returns a copy of the value.

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

Performs copy-assignment from source.

impl ConnectOptions for StdioConnectOptions

fn set_timeout(&mut self, _: Duration) -> StdioResult<&mut Self>

This parameter is ignored because connection can never fail

type Error = StdioErr

fn timeout(&self) -> StdioResult<Duration>

impl Debug for StdioConnectOptions

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

Formats the value using the given formatter.

impl Default for StdioConnectOptions

fn default() -> StdioConnectOptions

Returns the “default value” for a type.