Crate dfir_pipes 

Pull and push-based stream combinators for dataflow pipelines.

This crate provides a pull::Pull trait and a push::Push trait, along with collections of composable operators for building pull-based and push-based data pipelines. Operators are chained via trait methods on pull::Pull (same as iterator adapters) or module functions in push.

Re-exports

pub use itertools;

Modules

pull

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

push

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

Structs

Yes

Type-level true for Toggle.

Enums

Either

The enum Either with variants Left and Right is a general purpose sum type with two cases.

EitherOrBoth

Value that either holds a single A or B, or both.

No

Type-level false for Toggle.

Traits

Context

Context trait for pull-based streams, allowing operators to be generic over synchronous (()) and asynchronous (core::task::Context) execution contexts.

FusedStream

A stream which tracks whether or not the underlying stream should no longer be polled.

Sink

A Sink is a value into which other values can be sent, asynchronously.

Stream

A stream of values produced asynchronously.

Toggle

A sealed trait for type-level booleans used to track pull capabilities.