Struct nakadion::Consumer
[−]
[src]
pub struct Consumer { /* fields omitted */ }
The consumer connects to the stream and sends batch lines to the processor.
This is the top level component used by an application that wants to consume a Nakadi stream
Methods
impl Consumer
[src]
pub fn start<C, A, HF>(
streaming_client: C,
api_client: A,
subscription_id: SubscriptionId,
handler_factory: HF,
commit_strategy: CommitStrategy
) -> Consumer where
C: StreamingClient + Clone + Send + 'static,
A: ApiClient + Clone + Send + 'static,
HF: HandlerFactory + Send + Sync + 'static,
[src]
streaming_client: C,
api_client: A,
subscription_id: SubscriptionId,
handler_factory: HF,
commit_strategy: CommitStrategy
) -> Consumer where
C: StreamingClient + Clone + Send + 'static,
A: ApiClient + Clone + Send + 'static,
HF: HandlerFactory + Send + Sync + 'static,