Trait nakadion::streaming_client::StreamingClient

pub trait StreamingClient {
    type LineIterator: Iterator<Item = LineResult>;
    fn connect(
        &self, 
        subscription_id: &SubscriptionId, 
        flow_id: FlowId
    ) -> Result<(StreamId, Self::LineIterator), ConnectError>;
}

A client for connecting to a subscription on the Nakadi Event Broker

Associated Types

type LineIterator: Iterator<Item = LineResult>

Required Methods

fn connect(
    &self,
    subscription_id: &SubscriptionId,
    flow_id: FlowId
) -> Result<(StreamId, Self::LineIterator), ConnectError>

Establish a connection for stream consumption.

Implementors

• impl<M> StreamingClient for NakadiStreamingClient<M> where     M: MetricsCollector,  type LineIterator = NakadiLineIterator;