Struct DataLoaderBuilder 

pub struct DataLoaderBuilder<S: DataSource> { /* private fields */ }

Builder for DataLoader.

Example

let loader = DataLoader::<TradingViewSource>::builder()
    .source(tv_source)
    .sink(channel_sink)
    .channel_capacity(8192)
    .build()?;

Implementations

impl<S: DataSource> DataLoaderBuilder<S>

pub fn new() -> Self

Create a new builder with defaults.

pub fn source(self, source: S) -> Self

Set the data source (required).

pub fn sink(self, sink: impl EventSink) -> Self

Register an event sink. You can call this multiple times to fan out to several sinks.

pub fn channel_capacity(self, capacity: usize) -> Self

Override the default channel capacity (4096).

pub fn continue_on_sink_error(self, val: bool) -> Self

If true, the loader keeps running even when a sink rejects events.

pub fn build(self) -> Result<DataLoader<S>>

Finish building the DataLoader.

Errors

• No source configured.
• No sinks registered.

Trait Implementations

impl<S: DataSource> Default for DataLoaderBuilder<S>

fn default() -> Self

Returns the “default value” for a type.