Method newStream

aibridge/intercept/messages/streaming.go:685–691

newStream traces svc.NewStreaming() call.

(ctx context.Context, svc anthropic.MessageService, extraOpts ...option.RequestOption)

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

	opts := append([]option.RequestOption{i.withBody()}, extraOpts...)
	return svc.NewStreaming(ctx, anthropic.MessageNewParams{}, opts...)
}