[−][src]Trait nakadion::components::connector::ConnectsExt

pub trait ConnectsExt: Connects + Sync {
    fn frame_stream(
        &self, 
        subscription_id: SubscriptionId
    ) -> ConnectFuture<(StreamId, FramesStream)> { ... }

    fn batch_stream(
        &self, 
        subscription_id: SubscriptionId
    ) -> ConnectFuture<(StreamId, BatchStream)> { ... }

    fn events_stream<E: DeserializeOwned>(
        &self, 
        subscription_id: SubscriptionId
    ) -> ConnectFuture<(StreamId, EventsStream<E>)> { ... }
}

Connects with extensions

Provided methods

fn frame_stream(
    &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)>

Get a stream of analyzed lines.

fn events_stream<E: DeserializeOwned>(
    &self,
    subscription_id: SubscriptionId
) -> ConnectFuture<(StreamId, EventsStream<E>)>

Get a stream of deserialized events.

Loading content...

Implementors

impl<T> ConnectsExt for T where
    T: Connects + Sync, [src]

Loading content...