Module pull 

Pull-based stream combinators. Pull-based stream combinators for dataflow pipelines.

This module provides pull-based operators that can be chained via method calls on pull::Pull, similar to iterator adapters.

Re-exports

pub use half_join_state::HalfJoinState;std

pub use half_join_state::HalfMultisetJoinState;std

pub use half_join_state::HalfSetJoinState;std

Modules

half_join_statestd

State management for symmetric hash joins.

Structs

AccumulateAllstd

Future for accumulate_all.

Chain

Pull combinator that chains two pulls in sequence.

Collect

Future that collects all items from a pull into a collection.

CrossSingleton

Pull combinator that crosses each item from item_pull with a singleton value from singleton_pull.

Empty

A pull that yields no items and immediately ends.

Enumerate

Pull combinator that pairs each item with its index.

Filter

Pull combinator that yields only items matching a predicate.

FilterMap

Pull combinator that both filters and maps items.

FlatMap

Pull combinator that maps each item to an iterator and flattens the results.

Flatten

Pull combinator that flattens nested iterables.

FlattenStream

Pull combinator that flattens items that are streams by polling each inner stream.

Foldstd

Fold with an initialization and fold function.

FoldFromstd

Fold but with initialization by converting the first received item.

ForEach

Future that runs a closure on each item from a pull.

FromFn

A Pull implementation created from a closure.

Fuse

Pull combinator that guarantees PullStep::Ended is returned forever after the first end.

Inspect

Pull combinator that calls a closure on each item for side effects, passing the item through.

Iter

A pull that wraps an iterator.

Map

Pull combinator that transforms each item with a closure.

NewTickJoinIterstd

Iterator for new tick - iterates over all matches after both sides are drained.

Next

A future which resolves with the next item from a Pull.

Once

A pull that yields a single item.

Pending

A pull that is always pending and never yields items or ends.

PollFn

A Pull implementation created from a closure.

Reducestd

Reduce with a reduce function.

Repeat

A pull that yields clones of an item forever.

SendPush

Future for pulling from a Pull and pushing to a Push.

SendSink

Future for pulling from a Pull and pushing to a Sink.

Skip

Pull combinator that skips the first n items.

SkipWhile

Pull combinator that skips items while a predicate returns true.

Stream

A pull that wraps a futures::Stream.

StreamCompat

Adapter that wraps a Pull to implement the Stream trait.

StreamReady

A Pull implementation that wraps a Stream and a Waker.

SymmetricHashJoinstd

Pull combinator for symmetric hash join operations.

Take

Pull combinator that yields the first n items.

TakeWhile

Pull combinator that yields items while a predicate returns true.

Zip

A pull that zips two pulls together, ending when either is exhausted.

ZipLongest

A pull that zips two pulls together, continuing until both are exhausted.

Enums

PullStep

The result of polling a Pull.

Traits

Accumulatorstd

Generalization of fold, reduce, etc.

FusedPull

A marker trait for pulls that are “fused”.

Pull

The Pull trait represents a pull-based stream that can be polled for items.

Functions

accumulate_allstd

Use the accumulator accum to accumulate all entries in the Pull prev into the hash_map.

empty

Creates an empty pull that immediately ends.

from_fn

Creates a synchronous pull from a closure.

iter

Creates a pull from an iterator.

once

Creates a pull that yields a single item.

pending

Creates a pull that is always pending and never yields items or ends.

poll_fn

Creates an asynchronous or synchronous pull from a closure.

repeat

Creates a pull that yields clones of the given item forever.

stream

Creates a pull from a futures::Stream.

stream_compat

Creates a StreamCompat adapter that wraps a Pull and implements futures_core::stream::Stream.

stream_ready

Creates a pull from a futures::Stream with a custom waker.

symmetric_hash_joinstd

Creates a symmetric hash join Pull from two input Pulls and their join states.

Type Aliases

SymmetricHashJoinEitherstd

Type alias for the Either pull returned by symmetric_hash_join.