PartitionedStream

fluxion_stream::partition

Struct PartitionedStream 

Source 
pub struct PartitionedStream<T: Fluxion>
where
    T::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static,
    T::Timestamp: Debug + Ord + Copy + Send + Sync + 'static,
{ /* private fields */ }
Expand description

A partitioned stream that keeps the routing task alive.

This stream wraps an inner stream and holds an Arc reference to the routing task guard. The task remains alive as long as either partitioned stream exists. When both streams are dropped, the task is aborted.

Implements Stream by delegating to the inner stream.

Trait Implementations§

Source§

impl<T: Fluxion> Debug for PartitionedStream<T>
where T::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, T::Timestamp: Debug + Ord + Copy + Send + Sync + 'static,

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl<T: Fluxion> Stream for PartitionedStream<T>
where T::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, T::Timestamp: Debug + Ord + Copy + Send + Sync + 'static,

Source§

type Item = StreamItem<T>

Values yielded by the stream.
Source§

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted. Read more
Source§

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T, S> CombineLatestExt<T> for S
where <T as Timestamped>::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, <T as HasTimestamp>::Timestamp: Clone + Debug + Ord + Copy + Send + Sync + 'static, S: Stream<Item = StreamItem<T>> + Send + Sync + 'static, CombinedState<<T as Timestamped>::Inner, <T as HasTimestamp>::Timestamp>: Timestamped<Inner = CombinedState<<T as Timestamped>::Inner, <T as HasTimestamp>::Timestamp>, Timestamp = <T as HasTimestamp>::Timestamp> + Send + Sync + 'static, T: Fluxion,

Source§

fn combine_latest<IS>( self, others: Vec<IS>, filter: impl Fn(&CombinedState<<T as Timestamped>::Inner, <T as HasTimestamp>::Timestamp>) -> bool + Send + Sync + 'static, ) -> impl Stream<Item = StreamItem<CombinedState<<T as Timestamped>::Inner, <T as HasTimestamp>::Timestamp>>> + Unpin + Send + Sync
where IS: IntoStream<Item = StreamItem<T>>, <IS as IntoStream>::Stream: Stream<Item = StreamItem<T>> + Send + Sync + 'static, CombinedState<<T as Timestamped>::Inner, <T as HasTimestamp>::Timestamp>: Timestamped<Inner = CombinedState<<T as Timestamped>::Inner, <T as HasTimestamp>::Timestamp>, Timestamp = <T as HasTimestamp>::Timestamp>,

Source§

impl<T, S> CombineWithPreviousExt<T> for S
where S: Stream<Item = StreamItem<T>> + Send + Sync + 'static, T: Fluxion, <T as Timestamped>::Inner: Debug + Ord + Unpin + Send + Sync + 'static, <T as HasTimestamp>::Timestamp: Debug + Ord + Copy + Send + Sync + 'static,

Source§

fn combine_with_previous( self, ) -> impl Stream<Item = StreamItem<WithPrevious<T>>> + Send + Sync

Pairs each stream element with its previous element. Read more
Source§

impl<T, S> DistinctUntilChangedByExt<T> for S
where S: Stream<Item = StreamItem<T>> + Send + Sync + 'static, T: Fluxion, <T as Timestamped>::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, <T as HasTimestamp>::Timestamp: Debug + Ord + Copy + Send + Sync + 'static,

Source§

fn distinct_until_changed_by<F>( self, compare: F, ) -> impl Stream<Item = StreamItem<T>> + Send + Sync
where F: Fn(&<T as Timestamped>::Inner, &<T as Timestamped>::Inner) -> bool + Send + Sync + 'static,

Source§

impl<T, S> DistinctUntilChangedExt<T> for S
where S: Stream<Item = StreamItem<T>> + Send + Sync + 'static, T: Fluxion, <T as Timestamped>::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, <T as HasTimestamp>::Timestamp: Debug + Ord + Copy + Send + Sync + 'static,

Source§

fn distinct_until_changed( self, ) -> impl Stream<Item = StreamItem<T>> + Send + Sync

Source§

impl<T, S> EmitWhenExt<T> for S
where S: Stream<Item = StreamItem<T>> + Unpin + Send + Sync + 'static, T: Fluxion, <T as Timestamped>::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, <T as HasTimestamp>::Timestamp: Debug + Ord + Copy + Send + Sync + 'static,

Source§

fn emit_when<IS>( self, filter_stream: IS, filter: impl Fn(&CombinedState<<T as Timestamped>::Inner, <T as HasTimestamp>::Timestamp>) -> bool + Send + Sync + 'static, ) -> impl Stream<Item = StreamItem<T>>
where IS: IntoStream<Item = StreamItem<T>>, <IS as IntoStream>::Stream: Send + Sync + 'static,

Emits source stream values only when the filter condition is satisfied. Read more
Source§

impl<S, T> FilterOrderedExt<T> for S
where S: Stream<Item = StreamItem<T>>, T: Fluxion, <T as Timestamped>::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, <T as HasTimestamp>::Timestamp: Debug + Ord + Copy + Send + Sync + 'static,

Source§

fn filter_ordered<F>( self, predicate: F, ) -> impl Stream<Item = StreamItem<T>> + Send + Sync
where S: Unpin + Send + Sync + 'static, F: FnMut(&<T as Timestamped>::Inner) -> bool + Send + Sync + 'static,

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<S> IntoStream for S
where S: Stream,

Source§

type Item = <S as Stream>::Item

The type of items in the stream.
Source§

type Stream = S

The stream type that this object can be converted into.
Source§

fn into_stream(self) -> <S as IntoStream>::Stream

Converts this object into a stream.
Source§

impl<S, T> MapOrderedExt<T> for S
where S: Stream<Item = StreamItem<T>>, T: Fluxion, <T as Timestamped>::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, <T as HasTimestamp>::Timestamp: Debug + Ord + Copy + Send + Sync + 'static,

Source§

fn map_ordered<U, F>( self, f: F, ) -> impl Stream<Item = StreamItem<U>> + Send + Sync
where S: Unpin + Send + Sync + 'static, U: Fluxion, <U as Timestamped>::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, <U as HasTimestamp>::Timestamp: Debug + Ord + Copy + Send + Sync + 'static, F: FnMut(T) -> U + Send + Sync + 'static,

Maps each item to a new value while preserving temporal ordering. Read more
Source§

impl<S, T> OnErrorExt<T> for S
where S: Stream<Item = StreamItem<T>> + Send + Sync + 'static, T: Send + Sync + 'static,

Source§

fn on_error<F>( self, handler: F, ) -> impl Stream<Item = StreamItem<T>> + Send + Sync
where F: FnMut(&FluxionError) -> bool + Send + Sync + 'static,

Handle errors in the stream with a handler function. Read more
Source§

impl<T, S> OrderedStreamExt<T> for S
where T: Fluxion + Unpin, <T as Timestamped>::Inner: Debug + Ord + Unpin + Send + Sync + 'static, <T as HasTimestamp>::Timestamp: Debug + Ord + Copy + Send + Sync + 'static, S: Stream<Item = StreamItem<T>> + Send + Sync + 'static,

Source§

fn ordered_merge<IS>( self, others: Vec<IS>, ) -> impl Stream<Item = StreamItem<T>> + Send + Sync
where IS: IntoStream<Item = StreamItem<T>>, <IS as IntoStream>::Stream: Stream<Item = StreamItem<T>> + Send + Sync + 'static,

Source§

impl<S, T> PartitionExt<T> for S
where S: Stream<Item = StreamItem<T>>, T: Fluxion, <T as Timestamped>::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, <T as HasTimestamp>::Timestamp: Debug + Ord + Copy + Send + Sync + 'static,

Source§

fn partition<F>( self, predicate: F, ) -> (PartitionedStream<T>, PartitionedStream<T>)
where S: Unpin + Send + Sync + 'static, F: Fn(&<T as Timestamped>::Inner) -> bool + Send + Sync + 'static,

Partitions the stream into two based on a predicate. Read more
Source§

impl<S, T> SampleRatioExt<T> for S
where S: Stream<Item = StreamItem<T>>, T: Fluxion, <T as Timestamped>::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, <T as HasTimestamp>::Timestamp: Debug + Ord + Copy + Send + Sync + 'static,

Source§

fn sample_ratio( self, ratio: f64, seed: u64, ) -> impl Stream<Item = StreamItem<T>> + Send + Sync
where S: Unpin + Send + Sync + 'static,

Randomly samples items from the stream with the given probability ratio. Read more
Source§

impl<T, S> ScanOrderedExt<T> for S
where S: Stream<Item = StreamItem<T>> + Send + Sync + 'static, T: Fluxion, <T as Timestamped>::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, <T as HasTimestamp>::Timestamp: Debug + Ord + Copy + Send + Sync + 'static,

Source§

fn scan_ordered<Out, Acc, F>( self, initial: Acc, accumulator: F, ) -> impl Stream<Item = StreamItem<Out>>
where Acc: Send + Sync + 'static, Out: Fluxion, <Out as Timestamped>::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, <Out as HasTimestamp>::Timestamp: From<<T as HasTimestamp>::Timestamp> + Debug + Ord + Copy + Send + Sync + 'static, F: FnMut(&mut Acc, &<T as Timestamped>::Inner) -> <Out as Timestamped>::Inner + Send + Sync + 'static,

Accumulates state across stream items, emitting intermediate results. Read more
Source§

impl<S, T> ShareExt<T> for S
where S: Stream<Item = StreamItem<T>>, T: Clone + Send + Sync + 'static,

Source§

fn share(self) -> FluxionShared<T>
where S: Unpin + Send + Sync + 'static,

Shares this stream among multiple subscribers. Read more
Source§

impl<S, T> SkipItemsExt<T> for S
where S: Stream<Item = StreamItem<T>> + Send + Sync,

Source§

fn skip_items(self, n: usize) -> impl Stream<Item = StreamItem<T>> + Send + Sync

Skips the first n items from the stream. Read more
Source§

impl<S, T> StartWithExt<T> for S
where S: Stream<Item = StreamItem<T>> + Send + Sync, T: Send + Sync,

Source§

fn start_with( self, initial_values: Vec<StreamItem<T>>, ) -> impl Stream<Item = StreamItem<T>> + Send + Sync

Prepends initial values to the stream. Read more
Source§

impl<T> StreamExt for T
where T: Stream + ?Sized,

Source§

fn next(&mut self) -> Next<'_, Self>
where Self: Unpin,

Creates a future that resolves to the next item in the stream. Read more
Source§

fn into_future(self) -> StreamFuture<Self>
where Self: Sized + Unpin,

Converts this stream into a future of (next_item, tail_of_stream). If the stream terminates, then the next item is None. Read more
Source§

fn map<T, F>(self, f: F) -> Map<Self, F>
where F: FnMut(Self::Item) -> T, Self: Sized,

Maps this stream’s items to a different type, returning a new stream of the resulting type. Read more
Source§

fn enumerate(self) -> Enumerate<Self>
where Self: Sized,

Creates a stream which gives the current iteration count as well as the next value. Read more
Source§

fn filter<Fut, F>(self, f: F) -> Filter<Self, Fut, F>
where F: FnMut(&Self::Item) -> Fut, Fut: Future<Output = bool>, Self: Sized,

Filters the values produced by this stream according to the provided asynchronous predicate. Read more
Source§

fn filter_map<Fut, T, F>(self, f: F) -> FilterMap<Self, Fut, F>
where F: FnMut(Self::Item) -> Fut, Fut: Future<Output = Option<T>>, Self: Sized,

Filters the values produced by this stream while simultaneously mapping them to a different type according to the provided asynchronous closure. Read more
Source§

fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F>
where F: FnMut(Self::Item) -> Fut, Fut: Future, Self: Sized,

Computes from this stream’s items new items of a different type using an asynchronous closure. Read more
Source§

fn collect<C>(self) -> Collect<Self, C>
where C: Default + Extend<Self::Item>, Self: Sized,

Transforms a stream into a collection, returning a future representing the result of that computation. Read more
Source§

fn unzip<A, B, FromA, FromB>(self) -> Unzip<Self, FromA, FromB>
where FromA: Default + Extend<A>, FromB: Default + Extend<B>, Self: Sized + Stream<Item = (A, B)>,

Converts a stream of pairs into a future, which resolves to pair of containers. Read more
Source§

fn concat(self) -> Concat<Self>
where Self: Sized, Self::Item: Extend<<Self::Item as IntoIterator>::Item> + IntoIterator + Default,

Concatenate all items of a stream into a single extendable destination, returning a future representing the end result. Read more
Source§

fn count(self) -> Count<Self>
where Self: Sized,

Drives the stream to completion, counting the number of items. Read more
Source§

fn cycle(self) -> Cycle<Self>
where Self: Sized + Clone,

Repeats a stream endlessly. Read more
Source§

fn fold<T, Fut, F>(self, init: T, f: F) -> Fold<Self, Fut, T, F>
where F: FnMut(T, Self::Item) -> Fut, Fut: Future<Output = T>, Self: Sized,

Execute an accumulating asynchronous computation over a stream, collecting all the values into one final result. Read more
Source§

fn any<Fut, F>(self, f: F) -> Any<Self, Fut, F>
where F: FnMut(Self::Item) -> Fut, Fut: Future<Output = bool>, Self: Sized,

Execute predicate over asynchronous stream, and return true if any element in stream satisfied a predicate. Read more
Source§

fn all<Fut, F>(self, f: F) -> All<Self, Fut, F>
where F: FnMut(Self::Item) -> Fut, Fut: Future<Output = bool>, Self: Sized,

Execute predicate over asynchronous stream, and return true if all element in stream satisfied a predicate. Read more
Source§

fn flatten(self) -> Flatten<Self>
where Self::Item: Stream, Self: Sized,

Flattens a stream of streams into just one continuous stream. Read more
Source§

fn flatten_unordered( self, limit: impl Into<Option<usize>>, ) -> FlattenUnorderedWithFlowController<Self, ()>
where Self::Item: Stream + Unpin, Self: Sized,

Flattens a stream of streams into just one continuous stream. Polls inner streams produced by the base stream concurrently. Read more
Source§

fn flat_map<U, F>(self, f: F) -> FlatMap<Self, U, F>
where F: FnMut(Self::Item) -> U, U: Stream, Self: Sized,

Maps a stream like StreamExt::map but flattens nested Streams. Read more
Source§

fn flat_map_unordered<U, F>( self, limit: impl Into<Option<usize>>, f: F, ) -> FlatMapUnordered<Self, U, F>
where U: Stream + Unpin, F: FnMut(Self::Item) -> U, Self: Sized,

Maps a stream like StreamExt::map but flattens nested Streams and polls them concurrently, yielding items in any order, as they made available. Read more
Source§

fn scan<S, B, Fut, F>(self, initial_state: S, f: F) -> Scan<Self, S, Fut, F>
where F: FnMut(&mut S, Self::Item) -> Fut, Fut: Future<Output = Option<B>>, Self: Sized,

Combinator similar to StreamExt::fold that holds internal state and produces a new stream. Read more
Source§

fn skip_while<Fut, F>(self, f: F) -> SkipWhile<Self, Fut, F>
where F: FnMut(&Self::Item) -> Fut, Fut: Future<Output = bool>, Self: Sized,

Skip elements on this stream while the provided asynchronous predicate resolves to true. Read more
Source§

fn take_while<Fut, F>(self, f: F) -> TakeWhile<Self, Fut, F>
where F: FnMut(&Self::Item) -> Fut, Fut: Future<Output = bool>, Self: Sized,

Take elements from this stream while the provided asynchronous predicate resolves to true. Read more
Source§

fn take_until<Fut>(self, fut: Fut) -> TakeUntil<Self, Fut>
where Fut: Future, Self: Sized,

Take elements from this stream until the provided future resolves. Read more
Source§

fn for_each<Fut, F>(self, f: F) -> ForEach<Self, Fut, F>
where F: FnMut(Self::Item) -> Fut, Fut: Future<Output = ()>, Self: Sized,

Runs this stream to completion, executing the provided asynchronous closure for each element on the stream. Read more
Source§

fn for_each_concurrent<Fut, F>( self, limit: impl Into<Option<usize>>, f: F, ) -> ForEachConcurrent<Self, Fut, F>
where F: FnMut(Self::Item) -> Fut, Fut: Future<Output = ()>, Self: Sized,

Runs this stream to completion, executing the provided asynchronous closure for each element on the stream concurrently as elements become available. Read more
Source§

fn take(self, n: usize) -> Take<Self>
where Self: Sized,

Creates a new stream of at most n items of the underlying stream. Read more
Source§

fn skip(self, n: usize) -> Skip<Self>
where Self: Sized,

Creates a new stream which skips n items of the underlying stream. Read more
Source§

fn fuse(self) -> Fuse<Self>
where Self: Sized,

Fuse a stream such that poll_next will never again be called once it has finished. This method can be used to turn any Stream into a FusedStream. Read more
Source§

fn by_ref(&mut self) -> &mut Self

Borrows a stream, rather than consuming it. Read more
Source§

fn catch_unwind(self) -> CatchUnwind<Self>
where Self: Sized + UnwindSafe,

Catches unwinding panics while polling the stream. Read more
Source§

fn boxed<'a>(self) -> Pin<Box<dyn Stream<Item = Self::Item> + Send + 'a>>
where Self: Sized + Send + 'a,

Wrap the stream in a Box, pinning it. Read more
Source§

fn boxed_local<'a>(self) -> Pin<Box<dyn Stream<Item = Self::Item> + 'a>>
where Self: Sized + 'a,

Wrap the stream in a Box, pinning it. Read more
Source§

fn buffered(self, n: usize) -> Buffered<Self>
where Self::Item: Future, Self: Sized,

An adaptor for creating a buffered list of pending futures. Read more
Source§

fn buffer_unordered(self, n: usize) -> BufferUnordered<Self>
where Self::Item: Future, Self: Sized,

An adaptor for creating a buffered list of pending futures (unordered). Read more
Source§

fn zip<St>(self, other: St) -> Zip<Self, St>
where St: Stream, Self: Sized,

An adapter for zipping two streams together. Read more
Source§

fn chain<St>(self, other: St) -> Chain<Self, St>
where St: Stream<Item = Self::Item>, Self: Sized,

Adapter for chaining two streams. Read more
Source§

fn peekable(self) -> Peekable<Self>
where Self: Sized,

Creates a new stream which exposes a peek method. Read more
Source§

fn chunks(self, capacity: usize) -> Chunks<Self>
where Self: Sized,

An adaptor for chunking up items of the stream inside a vector. Read more
Source§

fn ready_chunks(self, capacity: usize) -> ReadyChunks<Self>
where Self: Sized,

An adaptor for chunking up ready items of the stream inside a vector. Read more
Source§

fn forward<S>(self, sink: S) -> Forward<Self, S>
where S: Sink<Self::Ok, Error = Self::Error>, Self: Sized + TryStream,

A future that completes after the given stream has been fully processed into the sink and the sink has been flushed and closed. Read more
Source§

fn split<Item>(self) -> (SplitSink<Self, Item>, SplitStream<Self>)
where Self: Sized + Sink<Item>,

Splits this Stream + Sink object into separate Sink and Stream objects. Read more
Source§

fn inspect<F>(self, f: F) -> Inspect<Self, F>
where F: FnMut(&Self::Item), Self: Sized,

Do something with each item of this stream, afterwards passing it on. Read more
Source§

fn left_stream<B>(self) -> Either<Self, B>
where B: Stream<Item = Self::Item>, Self: Sized,

Wrap this stream in an Either stream, making it the left-hand variant of that Either. Read more
Source§

fn right_stream<B>(self) -> Either<B, Self>
where B: Stream<Item = Self::Item>, Self: Sized,

Wrap this stream in an Either stream, making it the right-hand variant of that Either. Read more
Source§

fn poll_next_unpin(&mut self, cx: &mut Context<'_>) -> Poll<Option<Self::Item>>
where Self: Unpin,

A convenience method for calling Stream::poll_next on Unpin stream types.
Source§

fn select_next_some(&mut self) -> SelectNextSome<'_, Self>
where Self: Unpin + FusedStream,

Returns a Future that resolves when the next item in this stream is ready. Read more
Source§

impl<S, T> TakeItemsExt<T> for S
where S: Stream<Item = StreamItem<T>> + Send + Sync,

Source§

fn take_items(self, n: usize) -> impl Stream<Item = StreamItem<T>> + Send + Sync

Emits only the first n items from the stream, then completes. Read more
Source§

impl<T, S> TakeLatestWhenExt<T> for S
where S: Stream<Item = StreamItem<T>> + Unpin + Send + Sync + 'static, T: Fluxion, <T as Timestamped>::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, <T as HasTimestamp>::Timestamp: Debug + Ord + Copy + Send + Sync + 'static,

Source§

fn take_latest_when<IS>( self, filter_stream: IS, filter: impl Fn(&<T as Timestamped>::Inner) -> bool + Send + Sync + 'static, ) -> impl Stream<Item = StreamItem<T>> + Send + Sync
where IS: IntoStream<Item = StreamItem<T>>, <IS as IntoStream>::Stream: Send + Sync + 'static,

Emits the latest value from the source stream when the filter stream emits a passing value. Read more
Source§

impl<TItem, TFilter, S, P> TakeWhileExt<TItem, TFilter, S> for P
where P: Stream<Item = StreamItem<TItem>> + Unpin + Send + Sync + 'static, TItem: Fluxion, <TItem as Timestamped>::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, <TItem as HasTimestamp>::Timestamp: Debug + Ord + Copy + Send + Sync + 'static, TFilter: Fluxion<Timestamp = <TItem as HasTimestamp>::Timestamp>, <TFilter as Timestamped>::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, S: Stream<Item = StreamItem<TFilter>> + Send + Sync + 'static,

Source§

fn take_while_with( self, filter_stream: S, filter: impl Fn(&<TFilter as Timestamped>::Inner) -> bool + Send + Sync + 'static, ) -> impl Stream<Item = StreamItem<TItem>>

Takes elements from the source stream while the filter predicate returns true. Read more
Source§

impl<S, T> TapExt<T> for S
where S: Stream<Item = StreamItem<T>> + Unpin + 'static + Send + Sync, T: Fluxion, <T as Timestamped>::Inner: Clone + Debug + Ord + Unpin + 'static + Send + Sync, <T as HasTimestamp>::Timestamp: Debug + Ord + Copy + 'static + Send + Sync,

Source§

fn tap<F>(self, f: F) -> impl Stream<Item = StreamItem<T>> + Send + Sync
where Self: Unpin + 'static + Send + Sync, F: FnMut(&T::Inner) + 'static + Send + Sync,

Invokes a side-effect function for each value without modifying the stream. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<S, T> WindowByCountExt<T> for S
where S: Stream<Item = StreamItem<T>> + 'static + Send + Sync, T: Fluxion, <T as Timestamped>::Inner: Clone + Debug + Ord + Unpin + 'static + Send + Sync, <T as HasTimestamp>::Timestamp: Debug + Ord + Copy + 'static + Send + Sync,

Source§

fn window_by_count<Out>( self, n: usize, ) -> impl Stream<Item = StreamItem<Out>> + Send + Sync
where Out: Fluxion<Inner = Vec<<T as Timestamped>::Inner>>, <Out as Timestamped>::Inner: Clone + Debug + Ord + Unpin + 'static + Send + Sync, <Out as HasTimestamp>::Timestamp: From<<T as HasTimestamp>::Timestamp> + Debug + Ord + Copy + 'static + Send + Sync,

Groups consecutive items into fixed-size windows (batches). Read more
Source§

impl<T, S> WithLatestFromExt<T> for S
where T: Fluxion, <T as Timestamped>::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, <T as HasTimestamp>::Timestamp: Debug + Ord + Copy + Send + Sync + 'static, S: Stream<Item = StreamItem<T>> + Unpin + Send + Sync + 'static,

Source§

fn with_latest_from<IS, R>( self, other: IS, result_selector: impl Fn(&CombinedState<<T as Timestamped>::Inner, <T as HasTimestamp>::Timestamp>) -> R + Send + Sync + 'static, ) -> impl Stream<Item = StreamItem<R>>
where IS: IntoStream<Item = StreamItem<T>>, <IS as IntoStream>::Stream: Send + Sync + 'static, R: Fluxion, <R as Timestamped>::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, <R as HasTimestamp>::Timestamp: From<<T as HasTimestamp>::Timestamp> + Debug + Ord + Copy + Send + Sync + 'static,

Combines elements from the primary stream (self) with the latest element from the secondary stream (other).