Skip to main content

Crate streamx

Crate streamx 

Source

Macros§

combine_latest
Combine the latest values from multiple streams.

Structs§

CombineLatest2Stream
A stream created by combine_latest!.
CombineLatest3Stream
A stream created by combine_latest!.
CombineLatest4Stream
A stream created by combine_latest!.
CombineLatest5Stream
A stream created by combine_latest!.
CombineLatest6Stream
A stream created by combine_latest!.
CombineLatest7Stream
A stream created by combine_latest!.
CombineLatest8Stream
A stream created by combine_latest!.
CombineLatestIterStream
A stream created by combine_latest_all or StreamCombineLatestAllExt::combine_latest_all.
DebounceStream
A stream that emits values from the source only after a particular time span (determined by a scheduler) has passed without another source emission.
DistinctUntilChangedByStream
A stream that only emits values when they differ from the previous value, using a custom comparison function.
DistinctUntilChangedStream
A stream that only emits values when they differ from the previous value.
LatestStream
A stream that yields only the latest value from the upstream when polled.
ShareReplayStream
ShareReplayStreamWeak
ShareStream
A clonable stream that multicasts items from a single upstream stream to all clones.
ShareStreamWeak
A weak handle to a ShareStream.
ThrottleStream
A stream that emits at most one value per scheduler window.
WithLatestFromStream
A stream that emits (source_item, latest_from_item) when the source emits.

Enums§

Scheduler

Traits§

StreamCombineLatestAllExt
Combine the latest values from a collection of streams.
StreamDebounceExt
Extension trait that adds .debounce() to streams.
StreamDistinctUntilChangedExt
Extension trait that adds .distinct_until_changed() to streams.
StreamLatestExt
Extension trait that adds .latest() to streams.
StreamMergeAllExt
Extension trait that adds .merge_all() to collections of streams.
StreamShareExt
Share-related stream extensions (e.g. share()).
StreamShareReplayExt
StreamThrottleExt
Extension trait that adds .throttle() to streams.
StreamWithLatestFromExt
Extension trait that adds .with_latest_from() to streams.

Functions§

combine_latest_all
Combine the latest values from a collection of streams.
merge_all
Merge a collection of streams into a single stream.

Type Aliases§

MergeAllStream
A stream created by merge_all or StreamMergeAllExt::merge_all.