Method newMessage

intercept/messages/blocking.go:338–343

(ctx context.Context, svc anthropic.MessageService)

}

func (i *BlockingInterception) newMessage(ctx context.Context, svc anthropic.MessageService) (_ *anthropic.Message, outErr error) {
	ctx, span := i.tracer.Start(ctx, "Intercept.ProcessRequest.Upstream", trace.WithAttributes(tracing.InterceptionAttributesFromContext(ctx)...))
	defer tracing.EndSpanErr(span, &outErr)

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