Type Definition nakadion::components::connector::EventsStream

type EventsStream<E> = BoxStream<'static, Result<(StreamedBatchMeta, Option<Vec<E>>), Error>>;