Method newStream

intercept/responses/streaming.go:214–220

(ctx context.Context, srv responses.ResponseService, opts []option.RequestOption)

}

func (i *StreamingResponsesInterceptor) newStream(ctx context.Context, srv responses.ResponseService, opts []option.RequestOption) *ssestream.Stream[responses.ResponseStreamEventUnion] {
	ctx, span := i.tracer.Start(ctx, "Intercept.ProcessRequest.Upstream", trace.WithAttributes(tracing.InterceptionAttributesFromContext(ctx)...))
	defer span.End()

	// The body is overridden by option.WithRequestBody(reqPayload) in requestOptions
	return srv.NewStreaming(ctx, responses.ResponseNewParams{}, opts...)
}