id_effect 0.4.0

Effect<A, E, R> (sync + async), capability DI, pipe — interpreter-style, no bundled executor
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

# Transducers on streams

[`transducer`](../../src/streaming/transducer.rs) provides [`Transducer`](../../src/streaming/transducer.rs) with the same shape as [`id_effect_optics::Transducer`](../../../../id_effect_optics/src/transducer.rs) (kept local to avoid a crate dependency cycle).

```rust
use id_effect::{Stream, Transducer, transducer_filter, transducer_map};

let xf = transducer_map(|n: i32| n + 1).compose(transducer_filter(|n: &i32| n % 2 == 0));
let out = Stream::from_iterable(1..=5).via_transducer(xf);
// [2, 4, 6]
```

- **`via_transducer`** — alias of **`transduce_items`**: map/filter pipeline per element, preserving order.
- **`Transducer::compose`** — inner transducer runs first, then outer (same as optics).
- Built-ins: **`transducer_map`**, **`transducer_filter`**.

For list-only transduction without streams, use `id_effect_optics` directly or `Transducer::transduce` on iterators.