MessageStreamExtension extension

Convenience extensions on Stream<MessageStreamEvent>.

on

Properties

stopReason Future<StopReason?>

Available on Stream<MessageStreamEvent>, provided by the MessageStreamExtension extension

Consumes the entire stream and returns the last stop reason.
no setter

Methods

accumulate() Stream<MessageStreamAccumulator>

Available on Stream<MessageStreamEvent>, provided by the MessageStreamExtension extension

Accumulates events, yielding the accumulator after each event.
collectText() Future<String>

Available on Stream<MessageStreamEvent>, provided by the MessageStreamExtension extension

Collects all text deltas into a single string.
inputJsonDeltas() Stream<String>

Available on Stream<MessageStreamEvent>, provided by the MessageStreamExtension extension

Yields individual input JSON delta strings as they arrive (for tool use).
textDeltas() Stream<String>

Available on Stream<MessageStreamEvent>, provided by the MessageStreamExtension extension

Yields individual text delta strings as they arrive.
thinkingDeltas() Stream<String>

Available on Stream<MessageStreamEvent>, provided by the MessageStreamExtension extension

Yields individual thinking delta strings as they arrive.