AIDK API Reference / aidk-kernel / tapStream
Function: tapStream() ​
ts
function tapStream<T>(stream: AsyncIterable<T>, tapper: (item: T) => void | Promise<void>): AsyncIterable<T>;Defined in: packages/kernel/src/stream.ts:94
Perform side effects on each stream item without modifying the stream.
Type Parameters ​
| Type Parameter | Description |
|---|---|
T | Item type |
Parameters ​
| Parameter | Type | Description |
|---|---|---|
stream | AsyncIterable<T> | Source async iterable |
tapper | (item: T) => void | Promise<void> | Side-effect function called for each item |
Returns ​
AsyncIterable<T>
Async iterable yielding the original items
Example ​
typescript
const logged = tapStream(events, (event) => {
console.log('Event:', event.type);
});
for await (const event of logged) {
processEvent(event);
}