Struct Source 

pub struct Source<Out, Mat = NotUsed> { /* private fields */ }

Implementations

impl<T: Send + 'static> Source<T, NotUsed>

pub fn channel(capacity: usize) -> Source<T, Channel<T>>

A source fed by a materialized Channel handle.

The source blueprint is inert until materialized. Each materialization creates a fresh channel and claims its one consumer slot immediately. Panics if capacity == 0.

impl<T: Send + 'static> Source<T, NotUsed>

pub fn queue_bounded(capacity: usize) -> Source<T, BoundedSourceQueue<T>>

A source fed by an external BoundedSourceQueue handle (lock-free, no overflow strategy; a full buffer drops). Panics if capacity == 0.

pub fn queue( capacity: usize, strategy: OverflowStrategy, ) -> Source<T, SourceQueue<T>>

A source fed by an external SourceQueue handle that applies strategy on overflow. Panics if capacity == 0.

impl<Out: Send + 'static, Mat: Send + 'static> Source<Out, Mat>

pub fn buffer(self, size: usize, strategy: OverflowStrategy) -> Self

pub fn conflate_with_seed<Agg, Seed, Aggregate>( self, seed: Seed, aggregate: Aggregate, ) -> Source<Agg, Mat>

where Agg: Send + 'static, Seed: Fn(Out) -> Agg + Send + Sync + 'static, Aggregate: Fn(Agg, Out) -> Agg + Send + Sync + 'static,

pub fn conflate( self, aggregate: impl Fn(Out, Out) -> Out + Send + Sync + 'static, ) -> Self

pub fn batch<Agg, Seed, Aggregate>( self, max: u64, seed: Seed, aggregate: Aggregate, ) -> Source<Agg, Mat>

where Agg: Send + 'static, Seed: Fn(Out) -> Agg + Send + Sync + 'static, Aggregate: Fn(Agg, Out) -> Agg + Send + Sync + 'static,

pub fn batch_weighted<Agg, Cost, Seed, Aggregate>( self, max: u64, cost_fn: Cost, seed: Seed, aggregate: Aggregate, ) -> Source<Agg, Mat>

where Agg: Send + 'static, Cost: Fn(&Out) -> u64 + Send + Sync + 'static, Seed: Fn(Out) -> Agg + Send + Sync + 'static, Aggregate: Fn(Agg, Out) -> Agg + Send + Sync + 'static,

pub fn expand<Next, Expand, Iter>(self, expand: Expand) -> Source<Next, Mat>

where Next: Send + 'static, Expand: Fn(Out) -> Iter + Send + Sync + 'static, Iter: Iterator<Item = Next> + Send + 'static,

pub fn extrapolate<Expand, Iter>( self, extrapolator: Expand, initial: Option<Out>, ) -> Self

where Out: Clone + Sync, Expand: Fn(Out) -> Iter + Send + Sync + 'static, Iter: Iterator<Item = Out> + Send + 'static,

pub fn aggregate_with_boundary<Agg, Emit, Allocate, Aggregate, Harvest>( self, allocate: Allocate, aggregate: Aggregate, harvest: Harvest, emit_on_timer: Option<AggregateTimer<Agg>>, ) -> Source<Emit, Mat>

where Agg: Send + 'static, Emit: Send + 'static, Allocate: Fn() -> Agg + Send + Sync + 'static, Aggregate: Fn(Agg, Out) -> (Agg, bool) + Send + Sync + 'static, Harvest: Fn(Agg) -> Emit + Send + Sync + 'static,

pub fn detach(self) -> Self

impl<Out: Send + 'static> Source<Out, NotUsed>

pub fn empty() -> Self

pub fn never() -> Self

pub fn failed(error: StreamError) -> Self

pub fn future<F, Fut>(future: F) -> Self

where F: Fn() -> Fut + Send + Sync + 'static, Fut: Future<Output = StreamResult<Out>> + Send + 'static,

pub fn future_source<F, Fut>(future: F) -> Self

where F: Fn() -> Fut + Send + Sync + 'static, Fut: Future<Output = StreamResult<Source<Out>>> + Send + 'static,

pub fn cycle<F, I>(factory: F) -> Self

where F: Fn() -> I + Send + Sync + 'static, I: IntoIterator<Item = Out>, I::IntoIter: Send + 'static,

pub fn unfold<State, F>(initial: State, f: F) -> Self

where State: Clone + Send + Sync + 'static, F: Fn(State) -> Option<(State, Out)> + Send + Sync + 'static,

pub fn unfold_async<State, F, Fut>(initial: State, f: F) -> Self

where State: Clone + Send + Sync + 'static, F: Fn(State) -> Fut + Send + Sync + 'static, Fut: Future<Output = StreamResult<Option<(State, Out)>>> + Send + 'static,

pub fn unfold_resource<Resource, Create, Read, Close>( create: Create, read: Read, close: Close, ) -> Self

where Resource: Send + 'static, Create: Fn() -> StreamResult<Resource> + Send + Sync + 'static, Read: Fn(&mut Resource) -> StreamResult<Option<Out>> + Send + Sync + 'static, Close: Fn(Resource) -> StreamResult<()> + Send + Sync + 'static,

pub fn unfold_resource_async<Resource, Create, CreateFut, Read, ReadFut, Close, CloseFut>( create: Create, read: Read, close: Close, ) -> Self

where Resource: Send + 'static, Create: Fn() -> CreateFut + Send + Sync + 'static, CreateFut: Future<Output = StreamResult<Resource>> + Send + 'static, Read: Fn(&mut Resource) -> ReadFut + Send + Sync + 'static, ReadFut: Future<Output = StreamResult<Option<Out>>> + Send + 'static, Close: Fn(Resource) -> CloseFut + Send + Sync + 'static, CloseFut: Future<Output = StreamResult<()>> + Send + 'static,

pub fn lazy_single<F>(create: F) -> Self

where F: Fn() -> Out + Send + Sync + 'static,

pub fn lazy_future<F, Fut>(create: F) -> Self

where F: Fn() -> Fut + Send + Sync + 'static, Fut: Future<Output = StreamResult<Out>> + Send + 'static,

pub fn lazy_source<InnerMat, F>( create: F, ) -> Source<Out, StreamCompletion<InnerMat>>

where InnerMat: Send + 'static, F: Fn() -> Source<Out, InnerMat> + Send + Sync + 'static,

pub fn lazy_future_source<InnerMat, F, Fut>( create: F, ) -> Source<Out, StreamCompletion<InnerMat>>

where InnerMat: Send + 'static, F: Fn() -> Fut + Send + Sync + 'static, Fut: Future<Output = StreamResult<Source<Out, InnerMat>>> + Send + 'static,

pub fn from_fn_iter<F, I>(factory: F) -> Self

where F: Fn() -> I + Send + Sync + 'static, I: IntoIterator<Item = Out>, I::IntoIter: Send + 'static,

impl<Out: Send + 'static, Mat: Send + 'static> Source<Out, Mat>

pub fn as_source_with_context<Ctx, F>( self, extract_context: F, ) -> SourceWithContext<Out, Ctx, Mat>

where Ctx: Send + 'static, F: Fn(&Out) -> Ctx + Send + Sync + 'static,

pub fn via<Next, FlowMat>( self, flow: Flow<Out, Next, FlowMat>, ) -> Source<Next, Mat>

where Next: Send + 'static, FlowMat: Send + 'static,

pub fn via_mat<Next, FlowMat, Combined, F>( self, flow: Flow<Out, Next, FlowMat>, combine: F, ) -> Source<Next, Combined>

where Next: Send + 'static, FlowMat: Send + 'static, Combined: Send + 'static, F: Fn(Mat, FlowMat) -> Combined + Send + Sync + 'static,

pub fn via_mat_with<Next, FlowMat, Combined, F>( self, flow: Flow<Out, Next, FlowMat>, combine: F, ) -> Source<Next, Combined>

where Next: Send + 'static, FlowMat: Send + 'static, Combined: Send + 'static, F: Fn(Mat, FlowMat) -> Combined + Send + Sync + 'static,

pub fn map<Next, F>(self, f: F) -> Source<Next, Mat>

where Next: Send + 'static, F: Fn(Out) -> Next + Send + Sync + 'static,

pub fn attributes(&self) -> &Attributes

pub fn with_attributes(self, attributes: Attributes) -> Self

pub fn add_attributes(self, attributes: Attributes) -> Self

pub fn named(self, name: impl Into<String>) -> Self

pub fn async_boundary(self) -> Self

Insert an async boundary after this source.

The boundary uses the same crate::AsyncBoundaryExecutionConfig defaults as the GraphDSL AsyncBoundary runner and hands elements across a bounded Ractor-backed queue. async_boundary is the Rust-friendly primary name; Source::r#async is provided as the Akka-mirroring alias.

pub fn async(self) -> Self

Akka-mirroring alias for Source::async_boundary.

pub fn async_boundary_with_config( self, config: AsyncBoundaryExecutionConfig, ) -> Self

Insert an async boundary with an explicit bounded handoff configuration.

config.buffer_size controls the number of elements that may be queued between the upstream and downstream fused regions. A zero buffer is rejected when the stream is materialized.

pub fn async_boundary_with_buffer(self, buffer_size: usize) -> Self

Insert an async boundary with a custom bounded handoff size.

pub fn try_map<Next, F>(self, f: F) -> Source<Next, Mat>

where Next: Send + 'static, F: Fn(Out) -> StreamResult<Next> + Send + Sync + 'static,

pub fn map_result<Next, F>(self, f: F) -> Source<Next, Mat>

where Next: Send + 'static, F: Fn(Out) -> StreamResult<Next> + Send + Sync + 'static,

👎Deprecated since 0.9.0:

renamed to try_map (idiomatic); the _result name still works

Deprecated alias for Source::try_map.

pub fn map_result_with_supervision<Next, F>( self, f: F, decider: SupervisionDecider, ) -> Source<Next, Mat>

where Next: Send + 'static, F: Fn(Out) -> StreamResult<Next> + Send + Sync + 'static,

pub fn filter<F>(self, predicate: F) -> Source<Out, Mat>

where F: Fn(&Out) -> bool + Send + Sync + 'static,

pub fn try_filter<F>(self, predicate: F) -> Source<Out, Mat>

where F: Fn(&Out) -> StreamResult<bool> + Send + Sync + 'static,

pub fn filter_result<F>(self, predicate: F) -> Source<Out, Mat>

where F: Fn(&Out) -> StreamResult<bool> + Send + Sync + 'static,

👎Deprecated since 0.9.0:

renamed to try_filter (idiomatic); the _result name still works

Deprecated alias for Source::try_filter.

pub fn filter_result_with_supervision<F>( self, predicate: F, decider: SupervisionDecider, ) -> Source<Out, Mat>

where F: Fn(&Out) -> StreamResult<bool> + Send + Sync + 'static,

pub fn filter_not<F>(self, predicate: F) -> Source<Out, Mat>

where F: Fn(&Out) -> bool + Send + Sync + 'static,

pub fn filter_map<Next, F>(self, f: F) -> Source<Next, Mat>

where Next: Send + 'static, F: Fn(Out) -> Option<Next> + Send + Sync + 'static,

pub fn try_filter_map<Next, F>(self, f: F) -> Source<Next, Mat>

where Next: Send + 'static, F: Fn(Out) -> StreamResult<Option<Next>> + Send + Sync + 'static,

pub fn filter_map_result<Next, F>(self, f: F) -> Source<Next, Mat>

where Next: Send + 'static, F: Fn(Out) -> StreamResult<Option<Next>> + Send + Sync + 'static,

👎Deprecated since 0.9.0:

renamed to try_filter_map (idiomatic); the _result name still works

Deprecated alias for Source::try_filter_map.

pub fn filter_map_result_with_supervision<Next, F>( self, f: F, decider: SupervisionDecider, ) -> Source<Next, Mat>

where Next: Send + 'static, F: Fn(Out) -> StreamResult<Option<Next>> + Send + Sync + 'static,

pub fn map_concat<Next, F, I>(self, f: F) -> Source<Next, Mat>

where Next: Send + 'static, F: Fn(Out) -> I + Send + Sync + 'static, I: IntoIterator<Item = Next>, I::IntoIter: Send + 'static,

pub fn try_map_concat<Next, F, I>(self, f: F) -> Source<Next, Mat>

where Next: Send + 'static, F: Fn(Out) -> StreamResult<I> + Send + Sync + 'static, I: IntoIterator<Item = Next>, I::IntoIter: Send + 'static,

pub fn map_concat_result<Next, F, I>(self, f: F) -> Source<Next, Mat>

where Next: Send + 'static, F: Fn(Out) -> StreamResult<I> + Send + Sync + 'static, I: IntoIterator<Item = Next>, I::IntoIter: Send + 'static,

👎Deprecated since 0.9.0:

renamed to try_map_concat (idiomatic); the _result name still works

Deprecated alias for Source::try_map_concat.

pub fn map_concat_result_with_supervision<Next, F, I>( self, f: F, decider: SupervisionDecider, ) -> Source<Next, Mat>

where Next: Send + 'static, F: Fn(Out) -> StreamResult<I> + Send + Sync + 'static, I: IntoIterator<Item = Next>, I::IntoIter: Send + 'static,

pub fn stateful_map<State, Next, F>( self, seed: State, f: F, ) -> Source<Next, Mat>

where State: Clone + Send + Sync + 'static, Next: Send + 'static, F: Fn(&mut State, Out) -> Next + Send + Sync + 'static,

pub fn try_stateful_map<State, Next, F>( self, seed: State, f: F, ) -> Source<Next, Mat>

where State: Clone + Send + Sync + 'static, Next: Send + 'static, F: Fn(&mut State, Out) -> StreamResult<Next> + Send + Sync + 'static,

pub fn stateful_map_result<State, Next, F>( self, seed: State, f: F, ) -> Source<Next, Mat>

where State: Clone + Send + Sync + 'static, Next: Send + 'static, F: Fn(&mut State, Out) -> StreamResult<Next> + Send + Sync + 'static,

👎Deprecated since 0.9.0:

renamed to try_stateful_map (idiomatic); the _result name still works

Deprecated alias for Source::try_stateful_map.

pub fn stateful_map_result_with_supervision<State, Next, F>( self, seed: State, f: F, decider: SupervisionDecider, ) -> Source<Next, Mat>

where State: Clone + Send + Sync + 'static, Next: Send + 'static, F: Fn(&mut State, Out) -> StreamResult<Next> + Send + Sync + 'static,

pub fn stateful_map_concat<State, Next, F, I>( self, seed: State, f: F, ) -> Source<Next, Mat>

where State: Clone + Send + Sync + 'static, Next: Send + 'static, F: Fn(&mut State, Out) -> I + Send + Sync + 'static, I: IntoIterator<Item = Next>, I::IntoIter: Send + 'static,

pub fn try_stateful_map_concat<State, Next, F, I>( self, seed: State, f: F, ) -> Source<Next, Mat>

where State: Clone + Send + Sync + 'static, Next: Send + 'static, F: Fn(&mut State, Out) -> StreamResult<I> + Send + Sync + 'static, I: IntoIterator<Item = Next>, I::IntoIter: Send + 'static,

pub fn stateful_map_concat_result<State, Next, F, I>( self, seed: State, f: F, ) -> Source<Next, Mat>

where State: Clone + Send + Sync + 'static, Next: Send + 'static, F: Fn(&mut State, Out) -> StreamResult<I> + Send + Sync + 'static, I: IntoIterator<Item = Next>, I::IntoIter: Send + 'static,

👎Deprecated since 0.9.0:

renamed to try_stateful_map_concat (idiomatic); the _result name still works

Deprecated alias for Source::try_stateful_map_concat.

pub fn stateful_map_concat_result_with_supervision<State, Next, F, I>( self, seed: State, f: F, decider: SupervisionDecider, ) -> Source<Next, Mat>

where State: Clone + Send + Sync + 'static, Next: Send + 'static, F: Fn(&mut State, Out) -> StreamResult<I> + Send + Sync + 'static, I: IntoIterator<Item = Next>, I::IntoIter: Send + 'static,

pub fn map_async<Next, F, Fut>( self, parallelism: usize, f: F, ) -> Source<Next, Mat>

where Next: Send + 'static, F: Fn(Out) -> Fut + Send + Sync + 'static, Fut: Future<Output = StreamResult<Next>> + Send + 'static,

pub fn map_async_with_supervision<Next, F, Fut>( self, parallelism: usize, f: F, decider: SupervisionDecider, ) -> Source<Next, Mat>

where Next: Send + 'static, F: Fn(Out) -> Fut + Send + Sync + 'static, Fut: Future<Output = StreamResult<Next>> + Send + 'static,

pub fn map_async_unordered<Next, F, Fut>( self, parallelism: usize, f: F, ) -> Source<Next, Mat>

where Next: Send + 'static, F: Fn(Out) -> Fut + Send + Sync + 'static, Fut: Future<Output = StreamResult<Next>> + Send + 'static,

pub fn map_async_unordered_with_supervision<Next, F, Fut>( self, parallelism: usize, f: F, decider: SupervisionDecider, ) -> Source<Next, Mat>

where Next: Send + 'static, F: Fn(Out) -> Fut + Send + Sync + 'static, Fut: Future<Output = StreamResult<Next>> + Send + 'static,

pub fn map_async_partitioned<Key, Next, Partition, F, Fut>( self, parallelism: usize, per_partition: usize, partition: Partition, f: F, ) -> Source<Next, Mat>

where Key: Clone + Eq + Hash + Send + 'static, Next: Send + 'static, Partition: Fn(&Out) -> Key + Send + Sync + 'static, F: Fn(Out) -> Fut + Send + Sync + 'static, Fut: Future<Output = StreamResult<Next>> + Send + 'static,

pub fn prefix_and_tail(self, n: usize) -> Source<(Vec<Out>, Source<Out>), Mat>

pub fn flat_map_prefix<Next, FlowMat, F>( self, n: usize, f: F, ) -> Source<Next, Mat>

where Next: Send + 'static, FlowMat: Send + 'static, F: Fn(Vec<Out>) -> Flow<Out, Next, FlowMat> + Send + Sync + 'static, Out: Clone,

pub fn group_by<Key, F>( self, max_substreams: usize, f: F, allow_closed_substream_recreation: bool, ) -> Source<Source<Out>, Mat>

where Key: Clone + Eq + Hash + Send + 'static, F: Fn(&Out) -> Key + Send + Sync + 'static, Out: Clone,

pub fn split_when<F>(self, predicate: F) -> Source<Source<Out>, Mat>

where F: Fn(&Out) -> bool + Send + Sync + 'static, Out: Clone,

pub fn split_after<F>(self, predicate: F) -> Source<Source<Out>, Mat>

where F: Fn(&Out) -> bool + Send + Sync + 'static, Out: Clone,

pub fn flat_map_concat<Next, NextMat, F>(self, f: F) -> Source<Next, Mat>

where Next: Send + 'static, NextMat: Send + 'static, F: Fn(Out) -> Source<Next, NextMat> + Send + Sync + 'static,

pub fn flat_map_merge<Next, NextMat, F>( self, breadth: usize, f: F, ) -> Source<Next, Mat>

where Next: Send + 'static, NextMat: Send + 'static, F: Fn(Out) -> Source<Next, NextMat> + Send + Sync + 'static,

pub fn take(self, n: usize) -> Source<Out, Mat>

pub fn drop(self, n: usize) -> Source<Out, Mat>

pub fn take_while<F>(self, predicate: F) -> Source<Out, Mat>

where F: Fn(&Out) -> bool + Send + Sync + 'static,

pub fn drop_while<F>(self, predicate: F) -> Source<Out, Mat>

where F: Fn(&Out) -> bool + Send + Sync + 'static,

pub fn limit(self, max: u64) -> Source<Out, Mat>

pub fn grouped(self, size: usize) -> Source<Vec<Out>, Mat>

pub fn scan<State, F>(self, seed: State, f: F) -> Source<State, Mat>

where State: Clone + Send + Sync + 'static, F: Fn(State, Out) -> State + Send + Sync + 'static,

pub fn scan_async<State, F, Fut>(self, seed: State, f: F) -> Source<State, Mat>

where State: Clone + Send + Sync + 'static, F: Fn(State, Out) -> Fut + Send + Sync + 'static, Fut: Future<Output = StreamResult<State>> + Send + 'static,

pub fn try_scan<State, F>(self, seed: State, f: F) -> Source<State, Mat>

where State: Clone + Send + Sync + 'static, F: Fn(State, Out) -> StreamResult<State> + Send + Sync + 'static,

pub fn scan_result<State, F>(self, seed: State, f: F) -> Source<State, Mat>

where State: Clone + Send + Sync + 'static, F: Fn(State, Out) -> StreamResult<State> + Send + Sync + 'static,

👎Deprecated since 0.9.0:

renamed to try_scan (idiomatic); the _result name still works

Deprecated alias for Source::try_scan.

pub fn scan_result_with_supervision<State, F>( self, seed: State, f: F, decider: SupervisionDecider, ) -> Source<State, Mat>

where State: Clone + Send + Sync + 'static, F: Fn(State, Out) -> StreamResult<State> + Send + Sync + 'static,

pub fn sliding(self, size: usize, step: usize) -> Source<Vec<Out>, Mat>

where Out: Clone,

pub fn fold<Acc, F>(self, zero: Acc, f: F) -> Source<Acc, Mat>

where Acc: Clone + Send + Sync + 'static, F: Fn(Acc, Out) -> Acc + Send + Sync + 'static,

pub fn fold_async<Acc, F, Fut>(self, zero: Acc, f: F) -> Source<Acc, Mat>

where Acc: Clone + Send + Sync + 'static, F: Fn(Acc, Out) -> Fut + Send + Sync + 'static, Fut: Future<Output = StreamResult<Acc>> + Send + 'static,

pub fn map_with_resource<Resource, Next, Create, F, Close>( self, create: Create, f: F, close: Close, ) -> Source<Next, Mat>

where Resource: Send + 'static, Next: Send + 'static, Create: Fn() -> StreamResult<Resource> + Send + Sync + 'static, F: Fn(&mut Resource, Out) -> StreamResult<Next> + Send + Sync + 'static, Close: Fn(Resource) -> StreamResult<Option<Next>> + Send + Sync + 'static,

pub fn try_fold<Acc, F>(self, zero: Acc, f: F) -> Source<Acc, Mat>

where Acc: Clone + Send + Sync + 'static, F: Fn(Acc, Out) -> StreamResult<Acc> + Send + Sync + 'static,

pub fn fold_result<Acc, F>(self, zero: Acc, f: F) -> Source<Acc, Mat>

where Acc: Clone + Send + Sync + 'static, F: Fn(Acc, Out) -> StreamResult<Acc> + Send + Sync + 'static,

👎Deprecated since 0.9.0:

renamed to try_fold (idiomatic); the _result name still works

Deprecated alias for Source::try_fold.

pub fn fold_result_with_supervision<Acc, F>( self, zero: Acc, f: F, decider: SupervisionDecider, ) -> Source<Acc, Mat>

where Acc: Clone + Send + Sync + 'static, F: Fn(Acc, Out) -> StreamResult<Acc> + Send + Sync + 'static,

pub fn reduce<F>(self, f: F) -> Source<Out, Mat>

where F: Fn(Out, Out) -> Out + Send + Sync + 'static,

pub fn try_reduce<F>(self, f: F) -> Source<Out, Mat>

where Out: Clone, F: Fn(Out, Out) -> StreamResult<Out> + Send + Sync + 'static,

pub fn reduce_result<F>(self, f: F) -> Source<Out, Mat>

where Out: Clone, F: Fn(Out, Out) -> StreamResult<Out> + Send + Sync + 'static,

👎Deprecated since 0.9.0:

renamed to try_reduce (idiomatic); the _result name still works

Deprecated alias for Source::try_reduce.

pub fn reduce_result_with_supervision<F>( self, f: F, decider: SupervisionDecider, ) -> Source<Out, Mat>

where Out: Clone, F: Fn(Out, Out) -> StreamResult<Out> + Send + Sync + 'static,

pub fn map_error<F>(self, f: F) -> Source<Out, Mat>

where F: Fn(StreamError) -> StreamError + Send + Sync + 'static,

pub fn recover<F>(self, f: F) -> Source<Out, Mat>

where F: Fn(StreamError) -> Option<Out> + Send + Sync + 'static,

pub fn recover_with<F>(self, f: F) -> Source<Out, Mat>

where F: Fn(StreamError) -> Option<Source<Out>> + Send + Sync + 'static,

pub fn recover_with_retries<F>(self, retries: usize, f: F) -> Source<Out, Mat>

where F: Fn(StreamError) -> Option<Source<Out>> + Send + Sync + 'static,

pub fn on_error_complete(self) -> Source<Out, Mat>

pub fn concat<Mat2>(self, that: Source<Out, Mat2>) -> Source<Out, Mat>

where Mat2: Send + 'static,

pub fn concat_lazy<Mat2>(self, that: Source<Out, Mat2>) -> Source<Out, Mat>

where Mat2: Send + 'static,

pub fn concat_all_lazy<Mat2, I>(self, those: I) -> Source<Out, Mat>

where Mat2: Send + 'static, I: IntoIterator<Item = Source<Out, Mat2>>,

pub fn prepend<Mat2>(self, that: Source<Out, Mat2>) -> Source<Out, Mat>

where Mat2: Send + 'static,

pub fn prepend_lazy<Mat2>(self, that: Source<Out, Mat2>) -> Source<Out, Mat>

where Mat2: Send + 'static,

pub fn or_else<Mat2>(self, secondary: Source<Out, Mat2>) -> Source<Out, Mat>

where Mat2: Send + 'static,

pub fn interleave<Mat2>( self, that: Source<Out, Mat2>, segment_size: usize, ) -> Source<Out, Mat>

where Mat2: Send + 'static,

pub fn interleave_all<Mat2, I>( self, those: I, segment_size: usize, eager_close: bool, ) -> Source<Out, Mat>

where Mat2: Send + 'static, I: IntoIterator<Item = Source<Out, Mat2>>,

pub fn merge_sorted<Mat2>(self, that: Source<Out, Mat2>) -> Source<Out, Mat>

where Out: Ord, Mat2: Send + 'static,

pub fn merge_latest<Mat2>( self, that: Source<Out, Mat2>, eager_complete: bool, ) -> Source<Vec<Out>, Mat>

where Out: Clone, Mat2: Send + 'static,

pub fn merge_all<Mat2, I>( self, those: I, eager_complete: bool, ) -> Source<Out, Mat>

where Mat2: Send + 'static, I: IntoIterator<Item = Source<Out, Mat2>>,

pub fn zip_with<Mat2, Out2, Next, F>( self, that: Source<Out2, Mat2>, combine: F, ) -> Source<Next, Mat>

where Out2: Send + 'static, Next: Send + 'static, Mat2: Send + 'static, F: Fn(Out, Out2) -> Next + Send + Sync + 'static,

pub fn zip_latest<Mat2, Out2>( self, that: Source<Out2, Mat2>, ) -> Source<(Out, Out2), Mat>

where Out: Clone, Out2: Clone + Send + 'static, Mat2: Send + 'static,

pub fn zip_latest_with<Mat2, Out2, Next, F>( self, that: Source<Out2, Mat2>, eager_complete: bool, combine: F, ) -> Source<Next, Mat>

where Out: Clone, Out2: Clone + Send + 'static, Next: Send + 'static, Mat2: Send + 'static, F: Fn(Out, Out2) -> Next + Send + Sync + 'static,

pub fn zip_with_index(self) -> Source<(Out, u64), Mat>

pub fn zip_all<Mat2, Out2>( self, that: Source<Out2, Mat2>, this_elem: Out, that_elem: Out2, ) -> Source<(Out, Out2), Mat>

where Out: Clone + Sync, Out2: Clone + Send + Sync + 'static, Mat2: Send + 'static,

pub fn also_to<SinkMat>(self, sink: Sink<Out, SinkMat>) -> Source<Out, Mat>

where Out: Clone, SinkMat: Send + 'static,

pub fn also_to_all<SinkMat, I>(self, sinks: I) -> Source<Out, Mat>

where Out: Clone, SinkMat: Send + 'static, I: IntoIterator<Item = Sink<Out, SinkMat>>,

pub fn divert_to<SinkMat, F>( self, sink: Sink<Out, SinkMat>, predicate: F, ) -> Source<Out, Mat>

where SinkMat: Send + 'static, F: Fn(&Out) -> bool + Send + Sync + 'static,

pub fn wire_tap<SinkMat>(self, sink: Sink<Out, SinkMat>) -> Source<Out, Mat>

where Out: Clone, SinkMat: Send + 'static,

pub fn run_with<SinkMat: Send + 'static>( self, sink: Sink<Out, SinkMat>, ) -> StreamResult<SinkMat>

pub fn run_with_materializer<SinkMat: Send + 'static>( self, sink: Sink<Out, SinkMat>, materializer: &Materializer, ) -> StreamResult<SinkMat>

pub fn to<SinkMat>(self, sink: Sink<Out, SinkMat>) -> RunnableGraph<Mat>

where SinkMat: Send + 'static,

pub fn to_mat<SinkMat, Combined, F>( self, sink: Sink<Out, SinkMat>, combine: F, ) -> RunnableGraph<Combined>

where SinkMat: Send + 'static, Combined: Send + 'static, F: Fn(Mat, SinkMat) -> Combined + Send + Sync + 'static,

pub fn run_collect(self) -> StreamResult<Vec<Out>>

pub fn run_fold<Acc, F>( self, zero: Acc, f: F, ) -> StreamResult<StreamCompletion<Acc>>

where Acc: Clone + Send + Sync + 'static, F: Fn(Acc, Out) -> Acc + Send + Sync + 'static,

pub fn run_foreach<F>(self, f: F) -> StreamResult<StreamCompletion<NotUsed>>

where F: Fn(Out) + Send + Sync + 'static,

pub fn run_for_each<F>(self, f: F) -> StreamResult<StreamCompletion<NotUsed>>

where F: Fn(Out) + Send + Sync + 'static,

pub fn run_reduce<F>(self, f: F) -> StreamResult<StreamCompletion<Out>>

where F: Fn(Out, Out) -> Out + Send + Sync + 'static,

pub fn map_materialized_value<NextMat, F>(self, f: F) -> Source<Out, NextMat>

where NextMat: Send + 'static, F: Fn(Mat) -> NextMat + Send + Sync + 'static,

impl<Out: Clone + Send + Sync + 'static> Source<Out, NotUsed>

pub fn combine<Mat1, Mat2, MatRest, I>( first: Source<Out, Mat1>, second: Source<Out, Mat2>, rest: I, strategy: SourceCombineStrategy, ) -> Source<Out, NotUsed>

where Mat1: Send + 'static, Mat2: Send + 'static, MatRest: Send + 'static, I: IntoIterator<Item = Source<Out, MatRest>>,

pub fn zip_n<Mat2, I>(sources: I) -> Source<Vec<Out>, NotUsed>

where I: IntoIterator<Item = Source<Out, Mat2>>, Mat2: Send + 'static, Out: Clone,

pub fn zip_with_n<Mat2, I, Next, F>( sources: I, zipper: F, ) -> Source<Next, NotUsed>

where I: IntoIterator<Item = Source<Out, Mat2>>, Mat2: Send + 'static, Next: Send + 'static, F: Fn(Vec<Out>) -> Next + Send + Sync + 'static,

pub fn merge_prioritized_n<Mat2, I>( sources_and_priorities: I, eager_complete: bool, ) -> Source<Out, NotUsed>

where I: IntoIterator<Item = (Source<Out, Mat2>, usize)>, Mat2: Send + 'static,

pub fn maybe() -> (MaybeHandle<Out>, Self)

pub fn single(item: Out) -> Self

pub fn repeat(item: Out) -> Self

pub fn from_iterable<I>(items: I) -> Self

where I: IntoIterator<Item = Out>,

impl<Out: Send + 'static, Mat: Send + 'static> Source<Out, Mat>

pub fn throttle( self, elements: u64, per: Duration, maximum_burst: i32, mode: ThrottleMode, ) -> Self

pub fn throttle_with_cost<CostFn>( self, cost: u64, per: Duration, maximum_burst: i32, cost_fn: CostFn, mode: ThrottleMode, ) -> Self

where CostFn: Fn(&Out) -> u64 + Send + Sync + 'static,

pub fn delay(self, delay: Duration, strategy: DelayOverflowStrategy) -> Self

pub fn delay_with<Supplier, Strategy>( self, delay_strategy_supplier: Supplier, overflow_strategy: DelayOverflowStrategy, ) -> Self

where Supplier: Fn() -> Strategy + Send + Sync + 'static, Strategy: FnMut(&Out) -> Duration + Send + 'static,

pub fn initial_delay(self, delay: Duration) -> Self

pub fn grouped_within( self, max_number: usize, interval: Duration, ) -> Source<Vec<Out>, Mat>

pub fn grouped_weighted_within<CostFn>( self, max_weight: u64, interval: Duration, cost_fn: CostFn, ) -> Source<Vec<Out>, Mat>

where CostFn: Fn(&Out) -> u64 + Send + Sync + 'static,

pub fn drop_within(self, timeout: Duration) -> Self

pub fn take_within(self, timeout: Duration) -> Self

pub fn idle_timeout(self, timeout: Duration) -> Self

pub fn backpressure_timeout(self, timeout: Duration) -> Self

pub fn completion_timeout(self, timeout: Duration) -> Self

pub fn initial_timeout(self, timeout: Duration) -> Self

pub fn keep_alive<Inject>(self, timeout: Duration, inject: Inject) -> Self

where Inject: Fn() -> Out + Send + Sync + 'static,

impl<Out: Clone + Send + Sync + 'static> Source<Out, Cancellable>

pub fn tick(initial_delay: Duration, interval: Duration, element: Out) -> Self

Trait Implementations

impl<Out: Clone, Mat: Clone> Clone for Source<Out, Mat>

fn clone(&self) -> Source<Out, Mat>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Out: Clone + Send + Sync + 'static> From<Vec<Out>> for Source<Out, NotUsed>

fn from(items: Vec<Out>) -> Self

Converts to this type from the input type.

impl<Out: Clone + Send + Sync + 'static, const N: usize> From<[Out; N]> for Source<Out, NotUsed>

fn from(items: [Out; N]) -> Self

Converts to this type from the input type.

impl<Out: Clone + Send + Sync + 'static> FromIterator<Out> for Source<Out, NotUsed>

fn from_iter<T: IntoIterator<Item = Out>>(iter: T) -> Self

Creates a value from an iterator.