Method newStream

intercept/messages/streaming.go:588–593

newStream traces svc.NewStreaming() call.

(ctx context.Context, svc anthropic.MessageService)

// newStream traces svc.NewStreaming() call.
func (i *StreamingInterception) newStream(ctx context.Context, svc anthropic.MessageService) *ssestream.Stream[anthropic.MessageStreamEventUnion] {
	_, span := i.tracer.Start(ctx, "Intercept.ProcessRequest.Upstream", trace.WithAttributes(tracing.InterceptionAttributesFromContext(ctx)...))
	defer span.End()

	return svc.NewStreaming(ctx, anthropic.MessageNewParams{}, i.withBody())
}