Module operator

Common operator transformations on timely streams and differential collections.

Structs

ConsolidateBuilder 🔒

A builder that wraps a session for direct output to a stream.

Traits

CollectionExt

Extension methods for differential Collections.

ConcatenateFlatten

Merge the contents of multiple streams and combine the containers using a container builder.

StreamExt

Extension methods for timely StreamCores.

Functions

consolidate_pact

Aggregates the weights of equal records into at most one record.

Type Aliases

SessionFor

A session with lifetime 'a in a scope G with a container builder CB.