stream-partition 0.1.0

Partition a single stream into multiple sub-streams based on a key
Documentation

stream-partition

CI status dependency status Last commit

A Rust library for partitioning a single stream into multiple sub-streams based on keys.

Overview

stream-partition provides a utility to split a stream into multiple sub-streams, where each sub-stream contains only items that match a specific key determined by an async function.

This can be used to process different types of items from a single stream with different logic.