Documentation / @agentick/core / tapStream

Function: tapStream()

tapStream<T>(stream, tapper): AsyncIterable<T>

Defined in: kernel/src/stream.ts:94

Perform side effects on each stream item without modifying the stream.

Type Parameters

T

T

Item type

Parameters

stream

AsyncIterable<T>

Source async iterable

tapper

(item) => void | Promise<void>

Side-effect function called for each item

Returns

AsyncIterable<T>

Async iterable yielding the original items

Example

const logged = tapStream(events, (event) => {
  console.log('Event:', event.type);
});
for await (const event of logged) {
  processEvent(event);
}