[−][src]Trait nakadion::components::connector::ConnectsExt
Connects
with extensions
Provided methods
fn frame_stream(
&self,
subscription_id: SubscriptionId
) -> ConnectFuture<(StreamId, FramesStream)>
&self,
subscription_id: SubscriptionId
) -> ConnectFuture<(StreamId, FramesStream)>
Get a stream of frames(lines) directly from Nakadi.
fn batch_stream(
&self,
subscription_id: SubscriptionId
) -> ConnectFuture<(StreamId, BatchStream)>
&self,
subscription_id: SubscriptionId
) -> ConnectFuture<(StreamId, BatchStream)>
Get a stream of analyzed lines.
fn events_stream<E: DeserializeOwned>(
&self,
subscription_id: SubscriptionId
) -> ConnectFuture<(StreamId, EventsStream<E>)>
&self,
subscription_id: SubscriptionId
) -> ConnectFuture<(StreamId, EventsStream<E>)>
Get a stream of deserialized events.