Struct dataflow::source::PubNubSourceReader

pub struct PubNubSourceReader {
    source_name: String,
    connector: PubNubSourceConnector,
}

Information required to sync data from PubNub

Fields

source_name: String

Used to produce useful error messages

connector: PubNubSourceConnector

Implementations

impl PubNubSourceReader

pub fn new(source_name: String, connector: PubNubSourceConnector) -> Self

Constructs a new instance

Trait Implementations

impl SimpleSource for PubNubSourceReader

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

Consumes the instance of this SimpleSource and converts it into an async state machine that submits rows using the provided timestamper.