eyeball_im_util/
vector.rsmod filter;
mod head;
mod ops;
mod skip;
mod sort;
mod tail;
mod traits;
use eyeball_im::VectorDiff;
use futures_core::Stream;
use self::ops::{VectorDiffContainerFamilyMember, VectorDiffContainerOps};
pub use self::{
filter::{Filter, FilterMap},
head::{EmptyLimitStream, Head},
skip::{EmptyCountStream, Skip},
sort::{Sort, SortBy, SortByKey},
tail::Tail,
traits::{
BatchedVectorSubscriber, VectorDiffContainer, VectorObserver, VectorObserverExt,
VectorSubscriberExt,
},
};
pub type VectorDiffContainerStreamElement<S> =
<<S as Stream>::Item as VectorDiffContainer>::Element;
pub type VectorDiffContainerStreamMappedItem<S, U> =
VectorDiffContainerFamilyMember<VectorDiffContainerStreamFamily<S>, U>;
type VectorDiffContainerStreamFamily<S> =
<<S as Stream>::Item as VectorDiffContainerOps<VectorDiffContainerStreamElement<S>>>::Family;
type VectorDiffContainerDiff<S> = VectorDiff<VectorDiffContainerStreamElement<S>>;
type VectorDiffContainerStreamHeadBuf<S> =
<<S as Stream>::Item as VectorDiffContainerOps<VectorDiffContainerStreamElement<S>>>::HeadBuf;
type VectorDiffContainerStreamTailBuf<S> =
<<S as Stream>::Item as VectorDiffContainerOps<VectorDiffContainerStreamElement<S>>>::TailBuf;
type VectorDiffContainerStreamSkipBuf<S> =
<<S as Stream>::Item as VectorDiffContainerOps<VectorDiffContainerStreamElement<S>>>::SkipBuf;
type VectorDiffContainerStreamSortBuf<S> =
<<S as Stream>::Item as VectorDiffContainerOps<VectorDiffContainerStreamElement<S>>>::SortBuf;