Struct TypedModelStream 

pub struct TypedModelStream<O> {
    pub stream: Pin<Box<dyn Stream<Item = Result<StreamDelta, Error>> + Send>>,
    pub completion: Pin<Box<dyn Future<Output = Result<O, Error>> + Send>>,
}

Streaming counterpart to a complete_typed call — raw deltas on stream, the aggregated typed payload on completion.

The stream field is identical to ModelStream::stream: raw StreamDeltas the consumer surfaces to the user (text fragments, thinking deltas, …) as the model emits them. The completion future resolves to the typed O parsed from the aggregated final response — operators await it once the stream has been drained.

Mirrors crate::service::ModelStream for the typed-output path; the underlying aggregator is the same tap_aggregator used by ChatModel::stream_deltas.

Fields

stream: Pin<Box<dyn Stream<Item = Result<StreamDelta, Error>> + Send>>

Raw delta stream surfaced to the consumer.

completion: Pin<Box<dyn Future<Output = Result<O, Error>> + Send>>

Future resolving to the typed O after the stream has been consumed to its terminal Stop. Drops the TypedModelStream before draining the stream to surface an Err on completion.

Trait Implementations

impl<O> Debug for TypedModelStream<O>

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.