Trait Loader 

pub trait Loader:
    DynClone
    + Send
    + Sync {
    type Output: Chunk;

    // Required method
    fn into_stream(self) -> IndexingStream<Self::Output>;

    // Provided methods
    fn into_stream_boxed(self: Box<Self>) -> IndexingStream<Self::Output> { ... }
    fn name(&self) -> &'static str { ... }
}

Starting point of a stream

Required Associated Types

type Output: Chunk

Required Methods

fn into_stream(self) -> IndexingStream<Self::Output>

Provided Methods

fn into_stream_boxed(self: Box<Self>) -> IndexingStream<Self::Output>

Intended for use with Box

Only needed if you use trait objects (Box)

Example

fn into_stream_boxed(self: Box<Self>) -> IndexingStream {
   self.into_stream()
 }

fn name(&self) -> &'static str

Trait Implementations

impl<O> Loader for Box<dyn Loader<Output = O>>

where O: Chunk,

type Output = O

fn into_stream( self, ) -> IndexingStream<<Box<dyn Loader<Output = O>> as Loader>::Output>

fn into_stream_boxed( self: Box<Box<dyn Loader<Output = O>>>, ) -> IndexingStream<<Box<dyn Loader<Output = O>> as Loader>::Output>

Intended for use with Box

fn name(&self) -> &'static str

impl<O> Loader for &dyn Loader<Output = O>

where O: Chunk,

type Output = O

fn into_stream(self) -> IndexingStream<&dyn Loader<Output = O>::Output>

fn into_stream_boxed( self: Box<&dyn Loader<Output = O>>, ) -> IndexingStream<&dyn Loader<Output = O>::Output>

Intended for use with Box

fn name(&self) -> &'static str

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl<O> Loader for Box<dyn Loader<Output = O>>

where O: Chunk,

type Output = O

fn into_stream( self, ) -> IndexingStream<<Box<dyn Loader<Output = O>> as Loader>::Output>

fn into_stream_boxed( self: Box<Box<dyn Loader<Output = O>>>, ) -> IndexingStream<<Box<dyn Loader<Output = O>> as Loader>::Output>

fn name(&self) -> &'static str

Implementors

impl Loader for FileLoader

type Output = String

impl Loader for Fluvio

type Output = String

impl Loader for Kafka

type Output = String

impl Loader for MockLoader

type Output = String

impl Loader for Parquet

type Output = String

impl Loader for ScrapingLoader

type Output = String

impl<O> Loader for &dyn Loader<Output = O>

where O: Chunk,

type Output = O