Channel Operators Internals
This page documents internals of groupTupleBy, joinBy, and combineBy.
Key Infrastructure
KeyExtractor validates closure arity and normalizes list keys into CompositeKey for stable equality/hash behavior.
Operator Implementation Notes
-
GroupTupleByOpgroups items by extracted key and flushes by options (size,remainder). -
JoinByOpindexes channels by key and emits merged items for matching keys. -
CombineByOpperforms keyed cartesian products within matching groups.
Error Handling
Operator constructors fail fast on invalid key-extractor closures. Runtime key extraction errors are wrapped with contextual messages for debugging.