Adding the TranscriptionBuilder

src/Libraries/Microsoft.Extensions.AI.Abstractions/AudioTranscription/DelegatingAudioTranscriptionClient.cs

@@ -51,14 +51,14 @@ protected virtual void Dispose(bool disposing)
     public virtual AudioTranscriptionClientMetadata Metadata => InnerClient.Metadata;
 
     /// <inheritdoc />
-    public virtual Task<AudioTranscriptionCompletion> TranscribeAsync(IReadOnlyList<
+    public virtual Task<AudioTranscriptionCompletion> TranscribeAsync(IList<
         IAsyncEnumerable<DataContent>> audioContents, AudioTranscriptionOptions? options = null, CancellationToken cancellationToken = default)
     {
         return InnerClient.TranscribeAsync(audioContents, options, cancellationToken);
     }
 
     /// <inheritdoc />
-    public virtual IAsyncEnumerable<StreamingAudioTranscriptionUpdate> TranscribeStreamingAsync(IReadOnlyList<
+    public virtual IAsyncEnumerable<StreamingAudioTranscriptionUpdate> TranscribeStreamingAsync(IList<
         IAsyncEnumerable<DataContent>> audioContents, AudioTranscriptionOptions? options = null, CancellationToken cancellationToken = default)
     {
         return InnerClient.TranscribeStreamingAsync(audioContents, options, cancellationToken);

src/Libraries/Microsoft.Extensions.AI.Abstractions/AudioTranscription/IAudioTranscriptionClient.cs

@@ -30,7 +30,7 @@ public interface IAudioTranscriptionClient : IDisposable
     /// <param name="cancellationToken">The <see cref="CancellationToken"/> to monitor for cancellation requests. The default is <see cref="CancellationToken.None"/>.</param>
     /// <returns>The transcriptions generated by the client.</returns>
     Task<AudioTranscriptionCompletion> TranscribeAsync(
-        IReadOnlyList<IAsyncEnumerable<DataContent>> audioContents,
+        IList<IAsyncEnumerable<DataContent>> audioContents,
         AudioTranscriptionOptions? options = null,
         CancellationToken cancellationToken = default);
 
@@ -40,7 +40,7 @@ Task<AudioTranscriptionCompletion> TranscribeAsync(
     /// <param name="cancellationToken">The <see cref="CancellationToken"/> to monitor for cancellation requests. The default is <see cref="CancellationToken.None"/>.</param>
     /// <returns>The response messages generated by the client.</returns>
     IAsyncEnumerable<StreamingAudioTranscriptionUpdate> TranscribeStreamingAsync(
-        IReadOnlyList<IAsyncEnumerable<DataContent>> audioContents,
+        IList<IAsyncEnumerable<DataContent>> audioContents,
         AudioTranscriptionOptions? options = null,
         CancellationToken cancellationToken = default);
 

src/Libraries/Microsoft.Extensions.AI.OpenAI/Microsoft.Extensions.AI.OpenAI.csproj

@@ -39,8 +39,4 @@
     <ProjectReference Include="../Microsoft.Extensions.AI.Abstractions/Microsoft.Extensions.AI.Abstractions.csproj" />
   </ItemGroup>
 
-  <ItemGroup>
-    <Folder Include="ChatCompletion\" />
-  </ItemGroup>
-
 </Project>

src/Libraries/Microsoft.Extensions.AI.OpenAI/OpenAIAudioTranscriptionClient.cs

@@ -164,7 +164,7 @@ public async IAsyncEnumerable<StreamingAudioTranscriptionUpdate> TranscribeStrea
             {
                 yield return new StreamingAudioTranscriptionUpdate(choice.Contents)
                 {
-                    ChoiceIndex = inputIndex,
+                    InputIndex = inputIndex,
                     Kind = AudioTranscriptionUpdateKind.Transcribed,
                     RawRepresentation = choice.RawRepresentation
                 };

src/Libraries/Microsoft.Extensions.AI.OpenAI/OpenAIClientExtensions.cs

@@ -2,6 +2,7 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 
 using OpenAI;
+using OpenAI.Audio;
 using OpenAI.Chat;
 using OpenAI.Embeddings;
 
@@ -23,6 +24,19 @@ public static IChatClient AsChatClient(this OpenAIClient openAIClient, string mo
     public static IChatClient AsChatClient(this ChatClient chatClient) =>
         new OpenAIChatClient(chatClient);
 
+    /// <summary>Gets an <see cref="IAudioTranscriptionClient"/> for use with this <see cref="OpenAIClient"/>.</summary>
+    /// <param name="openAIClient">The client.</param>
+    /// <param name="modelId">The model.</param>
+    /// <returns>An <see cref="IAudioTranscriptionClient"/> that can be used to transcribe audio via the <see cref="OpenAIClient"/>.</returns>
+    public static IAudioTranscriptionClient AsAudioTranscriptionClient(this OpenAIClient openAIClient, string modelId) =>
+        new OpenAIAudioTranscriptionClient(openAIClient, modelId);
+
+    /// <summary>Gets an <see cref="IAudioTranscriptionClient"/> for use with this <see cref="AudioClient"/>.</summary>
+    /// <param name="audioClient">The client.</param>
+    /// <returns>An <see cref="IAudioTranscriptionClient"/> that can be used to transcribe audio via the <see cref="AudioClient"/>.</returns>
+    public static IAudioTranscriptionClient AsAudioTranscriptionClient(this AudioClient audioClient) =>
+        new OpenAIAudioTranscriptionClient(audioClient);
+
     /// <summary>Gets an <see cref="IEmbeddingGenerator{String, Single}"/> for use with this <see cref="OpenAIClient"/>.</summary>
     /// <param name="openAIClient">The client.</param>
     /// <param name="modelId">The model to use.</param>

src/Libraries/Microsoft.Extensions.AI/AudioTranscription/AnonymousDelegatingAudioTranscriptionClient.cs

@@ -0,0 +1,217 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Threading;
+using System.Threading.Channels;
+using System.Threading.Tasks;
+using Microsoft.Shared.Diagnostics;
+
+#pragma warning disable VSTHRD003 // Avoid awaiting foreign Tasks
+
+namespace Microsoft.Extensions.AI;
+
+/// <summary>A delegating audio transcription client that wraps an inner client with implementations provided by delegates.</summary>
+public sealed class AnonymousDelegatingAudioTranscriptionClient : DelegatingAudioTranscriptionClient
+{
+    /// <summary>The delegate to use as the implementation of <see cref="TranscribeAsync"/>.</summary>
+    private readonly Func<IList<IAsyncEnumerable<DataContent>>, AudioTranscriptionOptions?, IAudioTranscriptionClient, CancellationToken, Task<AudioTranscriptionCompletion>>? _transcribeFunc;
+
+    /// <summary>The delegate to use as the implementation of <see cref="TranscribeStreamingAsync"/>.</summary>
+    /// <remarks>
+    /// When non-<see langword="null"/>, this delegate is used as the implementation of <see cref="TranscribeStreamingAsync"/> and
+    /// will be invoked with the same arguments as the method itself, along with a reference to the inner client.
+    /// When <see langword="null"/>, <see cref="TranscribeStreamingAsync"/> will delegate directly to the inner client.
+    /// </remarks>
+    private readonly Func<
+        IList<IAsyncEnumerable<DataContent>>, AudioTranscriptionOptions?, IAudioTranscriptionClient, CancellationToken, IAsyncEnumerable<StreamingAudioTranscriptionUpdate>>? _transcribeStreamingFunc;
+
+    /// <summary>The delegate to use as the implementation of both <see cref="TranscribeAsync"/> and <see cref="TranscribeStreamingAsync"/>.</summary>
+    private readonly TranscribeSharedFunc? _sharedFunc;
+
+    /// <summary>
+    /// Initializes a new instance of the <see cref="AnonymousDelegatingAudioTranscriptionClient"/> class.
+    /// </summary>
+    /// <param name="innerClient">The inner client.</param>
+    /// <param name="sharedFunc">
+    /// A delegate that provides the implementation for both <see cref="TranscribeAsync"/> and <see cref="TranscribeStreamingAsync"/>.
+    /// In addition to the arguments for the operation, it's provided with a delegate to the inner client that should be
+    /// used to perform the operation on the inner client. It will handle both the non-streaming and streaming cases.
+    /// </param>
+    /// <remarks>
+    /// This overload may be used when the anonymous implementation needs to provide pre- and/or post-processing, but doesn't
+    /// need to interact with the results of the operation, which will come from the inner client.
+    /// </remarks>
+    /// <exception cref="ArgumentNullException"><paramref name="innerClient"/> is <see langword="null"/>.</exception>
+    /// <exception cref="ArgumentNullException"><paramref name="sharedFunc"/> is <see langword="null"/>.</exception>
+    public AnonymousDelegatingAudioTranscriptionClient(IAudioTranscriptionClient innerClient, TranscribeSharedFunc sharedFunc)
+        : base(innerClient)
+    {
+        _ = Throw.IfNull(sharedFunc);
+
+        _sharedFunc = sharedFunc;
+    }
+
+    /// <summary>
+    /// Initializes a new instance of the <see cref="AnonymousDelegatingAudioTranscriptionClient"/> class.
+    /// </summary>
+    /// <param name="innerClient">The inner client.</param>
+    /// <param name="transcribeFunc">
+    /// A delegate that provides the implementation for <see cref="TranscribeAsync"/>. When <see langword="null"/>,
+    /// <paramref name="transcribeStreamingFunc"/> must be non-null, and the implementation of <see cref="TranscribeAsync"/>
+    /// will use <paramref name="transcribeStreamingFunc"/> for the implementation.
+    /// </param>
+    /// <param name="transcribeStreamingFunc">
+    /// A delegate that provides the implementation for <see cref="TranscribeStreamingAsync"/>. When <see langword="null"/>,
+    /// <paramref name="transcribeFunc"/> must be non-null, and the implementation of <see cref="TranscribeStreamingAsync"/>
+    /// will use <paramref name="transcribeFunc"/> for the implementation.
+    /// </param>
+    /// <exception cref="ArgumentNullException"><paramref name="innerClient"/> is <see langword="null"/>.</exception>
+    /// <exception cref="ArgumentNullException">Both <paramref name="transcribeFunc"/> and <paramref name="transcribeStreamingFunc"/> are <see langword="null"/>.</exception>
+    public AnonymousDelegatingAudioTranscriptionClient(
+        IAudioTranscriptionClient innerClient,
+        Func<IList<IAsyncEnumerable<DataContent>>, AudioTranscriptionOptions?, IAudioTranscriptionClient, CancellationToken, Task<AudioTranscriptionCompletion>>? transcribeFunc,
+        Func<
+            IList<IAsyncEnumerable<DataContent>>,
+            AudioTranscriptionOptions?, IAudioTranscriptionClient, CancellationToken, IAsyncEnumerable<StreamingAudioTranscriptionUpdate>>? transcribeStreamingFunc)
+        : base(innerClient)
+    {
+        ThrowIfBothDelegatesNull(transcribeFunc, transcribeStreamingFunc);
+
+        _transcribeFunc = transcribeFunc;
+        _transcribeStreamingFunc = transcribeStreamingFunc;
+    }
+
+    /// <inheritdoc/>
+    public override Task<AudioTranscriptionCompletion> TranscribeAsync(
+        IList<IAsyncEnumerable<DataContent>> audioContents, AudioTranscriptionOptions? options = null, CancellationToken cancellationToken = default)
+    {
+        _ = Throw.IfNull(audioContents);
+
+        if (_sharedFunc is not null)
+        {
+            return TranscribeViaSharedAsync(audioContents, options, cancellationToken);
+
+            async Task<AudioTranscriptionCompletion> TranscribeViaSharedAsync(
+                IList<IAsyncEnumerable<DataContent>> audioContents, AudioTranscriptionOptions? options, CancellationToken cancellationToken)
+            {
+                AudioTranscriptionCompletion? completion = null;
+                await _sharedFunc(audioContents, options, async (audioContents, options, cancellationToken) =>
+                {
+                    completion = await InnerClient.TranscribeAsync(audioContents, options, cancellationToken).ConfigureAwait(false);
+                }, cancellationToken).ConfigureAwait(false);
+
+                if (completion is null)
+                {
+                    throw new InvalidOperationException("The wrapper completed successfully without producing a AudioTranscriptionCompletion.");
+                }
+
+                return completion;
+            }
+        }
+        else if (_transcribeFunc is not null)
+        {
+            return _transcribeFunc(audioContents, options, InnerClient, cancellationToken);
+        }
+        else
+        {
+            Debug.Assert(_transcribeStreamingFunc is not null, "Expected non-null streaming delegate.");
+            return _transcribeStreamingFunc!(audioContents, options, InnerClient, cancellationToken)
+                .ToAudioTranscriptionCompletionAsync(coalesceContent: true, cancellationToken);
+        }
+    }
+
+    /// <inheritdoc/>
+    public override IAsyncEnumerable<StreamingAudioTranscriptionUpdate> TranscribeStreamingAsync(
+        IList<IAsyncEnumerable<DataContent>> audioContents, AudioTranscriptionOptions? options = null, CancellationToken cancellationToken = default)
+    {
+        _ = Throw.IfNull(audioContents);
+
+        if (_sharedFunc is not null)
+        {
+            var updates = Channel.CreateBounded<StreamingAudioTranscriptionUpdate>(1);
+
+#pragma warning disable CA2016 // explicitly not forwarding the cancellation token, as we need to ensure the channel is always completed
+            _ = Task.Run(async () =>
+#pragma warning restore CA2016
+            {
+                Exception? error = null;
+                try
+                {
+                    await _sharedFunc(audioContents, options, async (audioContents, options, cancellationToken) =>
+                    {
+                        await foreach (var update in InnerClient.TranscribeStreamingAsync(audioContents, options, cancellationToken).ConfigureAwait(false))
+                        {
+                            await updates.Writer.WriteAsync(update, cancellationToken).ConfigureAwait(false);
+                        }
+                    }, cancellationToken).ConfigureAwait(false);
+                }
+                catch (Exception ex)
+                {
+                    error = ex;
+                    throw;
+                }
+                finally
+                {
+                    _ = updates.Writer.TryComplete(error);
+                }
+            });
+
+            return updates.Reader.ReadAllAsync(cancellationToken);
+        }
+        else if (_transcribeStreamingFunc is not null)
+        {
+            return _transcribeStreamingFunc(audioContents, options, InnerClient, cancellationToken);
+        }
+        else
+        {
+            Debug.Assert(_transcribeFunc is not null, "Expected non-null non-streaming delegate.");
+            return TranscribeStreamingAsyncViaTranscribeAsync(_transcribeFunc!(audioContents, options, InnerClient, cancellationToken));
+
+            static async IAsyncEnumerable<StreamingAudioTranscriptionUpdate> TranscribeStreamingAsyncViaTranscribeAsync(Task<AudioTranscriptionCompletion> task)
+            {
+                AudioTranscriptionCompletion completion = await task.ConfigureAwait(false);
+                foreach (var update in completion.ToStreamingAudioTranscriptionUpdates())
+                {
+                    yield return update;
+                }
+            }
+        }
+    }
+
+    /// <summary>Throws an exception if both of the specified delegates are null.</summary>
+    /// <exception cref="ArgumentNullException">Both <paramref name="transcribeFunc"/> and <paramref name="transcribeStreamingFunc"/> are <see langword="null"/>.</exception>
+    internal static void ThrowIfBothDelegatesNull(object? transcribeFunc, object? transcribeStreamingFunc)
+    {
+        if (transcribeFunc is null && transcribeStreamingFunc is null)
+        {
+            Throw.ArgumentNullException(nameof(transcribeFunc), $"At least one of the {nameof(transcribeFunc)} or {nameof(transcribeStreamingFunc)} delegates must be non-null.");
+        }
+    }
+
+    // Design note:
+    // The following delegate could juse use Func<...>, but it's defined as a custom delegate type
+    // in order to provide better discoverability / documentation / usability around its complicated
+    // signature with the nextAsync delegate parameter.
+
+    /// <summary>
+    /// Represents a method used to call <see cref="IAudioTranscriptionClient.TranscribeAsync"/> or <see cref="IAudioTranscriptionClient.TranscribeStreamingAsync"/>.
+    /// </summary>
+    /// <param name="audioContents">The audio contents to send.</param>
+    /// <param name="options">The audio transcription options to configure the request.</param>
+    /// <param name="nextAsync">
+    /// A delegate that provides the implementation for the inner client's <see cref="IAudioTranscriptionClient.TranscribeAsync"/> or
+    /// <see cref="IAudioTranscriptionClient.TranscribeStreamingAsync"/>. It should be invoked to continue the pipeline. It accepts
+    /// the audio contents, options, and cancellation token, which are typically the same instances as provided to this method
+    /// but need not be.
+    /// </param>
+    /// <param name="cancellationToken">The <see cref="CancellationToken"/> to monitor for cancellation requests. The default is <see cref="CancellationToken.None"/>.</param>
+    /// <returns>A <see cref="Task"/> that represents the completion of the operation.</returns>
+    public delegate Task TranscribeSharedFunc(
+        IList<IAsyncEnumerable<DataContent>> audioContents,
+        AudioTranscriptionOptions? options,
+        Func<IList<IAsyncEnumerable<DataContent>>, AudioTranscriptionOptions?, CancellationToken, Task> nextAsync,
+        CancellationToken cancellationToken);
+}

src/Libraries/Microsoft.Extensions.AI/AudioTranscription/AudioTranscriptionClientBuilder.cs

@@ -0,0 +1,140 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using Microsoft.Shared.Diagnostics;
+
+namespace Microsoft.Extensions.AI;
+
+/// <summary>A builder for creating pipelines of <see cref="IAudioTranscriptionClient"/>.</summary>
+public sealed class AudioTranscriptionClientBuilder
+{
+    private readonly Func<IServiceProvider, IAudioTranscriptionClient> _innerClientFactory;
+
+    /// <summary>The registered client factory instances.</summary>
+    private List<Func<IAudioTranscriptionClient, IServiceProvider, IAudioTranscriptionClient>>? _clientFactories;
+
+    /// <summary>Initializes a new instance of the <see cref="AudioTranscriptionClientBuilder"/> class.</summary>
+    /// <param name="innerClient">The inner <see cref="IAudioTranscriptionClient"/> that represents the underlying backend.</param>
+    public AudioTranscriptionClientBuilder(IAudioTranscriptionClient innerClient)
+    {
+        _ = Throw.IfNull(innerClient);
+        _innerClientFactory = _ => innerClient;
+    }
+
+    /// <summary>Initializes a new instance of the <see cref="AudioTranscriptionClientBuilder"/> class.</summary>
+    /// <param name="innerClientFactory">A callback that produces the inner <see cref="IAudioTranscriptionClient"/> that represents the underlying backend.</param>
+    public AudioTranscriptionClientBuilder(Func<IServiceProvider, IAudioTranscriptionClient> innerClientFactory)
+    {
+        _innerClientFactory = Throw.IfNull(innerClientFactory);
+    }
+
+    /// <summary>Builds an <see cref="IAudioTranscriptionClient"/> that represents the entire pipeline. Calls to this instance will pass through each of the pipeline stages in turn.</summary>
+    /// <param name="services">
+    /// The <see cref="IServiceProvider"/> that should provide services to the <see cref="IAudioTranscriptionClient"/> instances.
+    /// If null, an empty <see cref="IServiceProvider"/> will be used.
+    /// </param>
+    /// <returns>An instance of <see cref="IAudioTranscriptionClient"/> that represents the entire pipeline.</returns>
+    public IAudioTranscriptionClient Build(IServiceProvider? services = null)
+    {
+        services ??= EmptyServiceProvider.Instance;
+        var audioClient = _innerClientFactory(services);
+
+        // To match intuitive expectations, apply the factories in reverse order, so that the first factory added is the outermost.
+        if (_clientFactories is not null)
+        {
+            for (var i = _clientFactories.Count - 1; i >= 0; i--)
+            {
+                audioClient = _clientFactories[i](audioClient, services) ??
+                    throw new InvalidOperationException(
+                        $"The {nameof(AudioTranscriptionClientBuilder)} entry at index {i} returned null. " +
+                        $"Ensure that the callbacks passed to {nameof(Use)} return non-null {nameof(IAudioTranscriptionClient)} instances.");
+            }
+        }
+
+        return audioClient;
+    }
+
+    /// <summary>Adds a factory for an intermediate audio transcription client to the audio transcription client pipeline.</summary>
+    /// <param name="clientFactory">The client factory function.</param>
+    /// <returns>The updated <see cref="AudioTranscriptionClientBuilder"/> instance.</returns>
+    public AudioTranscriptionClientBuilder Use(Func<IAudioTranscriptionClient, IAudioTranscriptionClient> clientFactory)
+    {
+        _ = Throw.IfNull(clientFactory);
+
+        return Use((innerClient, _) => clientFactory(innerClient));
+    }
+
+    /// <summary>Adds a factory for an intermediate audio transcription client to the audio transcription client pipeline.</summary>
+    /// <param name="clientFactory">The client factory function.</param>
+    /// <returns>The updated <see cref="AudioTranscriptionClientBuilder"/> instance.</returns>
+    public AudioTranscriptionClientBuilder Use(Func<IAudioTranscriptionClient, IServiceProvider, IAudioTranscriptionClient> clientFactory)
+    {
+        _ = Throw.IfNull(clientFactory);
+
+        (_clientFactories ??= []).Add(clientFactory);
+        return this;
+    }
+
+    /// <summary>
+    /// Adds to the audio transcription client pipeline an anonymous delegating audio transcription client based on a delegate that provides
+    /// an implementation for both <see cref="IAudioTranscriptionClient.TranscribeAsync"/> and <see cref="IAudioTranscriptionClient.TranscribeStreamingAsync"/>.
+    /// </summary>
+    /// <param name="sharedFunc">
+    /// A delegate that provides the implementation for both <see cref="IAudioTranscriptionClient.TranscribeAsync"/> and
+    /// <see cref="IAudioTranscriptionClient.TranscribeStreamingAsync"/>. In addition to the arguments for the operation, it's
+    /// provided with a delegate to the inner client that should be used to perform the operation on the inner client.
+    /// It will handle both the non-streaming and streaming cases.
+    /// </param>
+    /// <returns>The updated <see cref="AudioTranscriptionClientBuilder"/> instance.</returns>
+    /// <remarks>
+    /// This overload may be used when the anonymous implementation needs to provide pre- and/or post-processing, but doesn't
+    /// need to interact with the results of the operation, which will come from the inner client.
+    /// </remarks>
+    /// <exception cref="ArgumentNullException"><paramref name="sharedFunc"/> is <see langword="null"/>.</exception>
+    public AudioTranscriptionClientBuilder Use(AnonymousDelegatingAudioTranscriptionClient.TranscribeSharedFunc sharedFunc)
+    {
+        _ = Throw.IfNull(sharedFunc);
+
+        return Use((innerClient, _) => new AnonymousDelegatingAudioTranscriptionClient(innerClient, sharedFunc));
+    }
+
+    /// <summary>
+    /// Adds to the audio transcription client pipeline an anonymous delegating audio transcription client based on a delegate that provides
+    /// an implementation for both <see cref="IAudioTranscriptionClient.TranscribeAsync"/> and <see cref="IAudioTranscriptionClient.TranscribeStreamingAsync"/>.
+    /// </summary>
+    /// <param name="transcribeFunc">
+    /// A delegate that provides the implementation for <see cref="IAudioTranscriptionClient.TranscribeAsync"/>. When <see langword="null"/>,
+    /// <paramref name="transcribeStreamingFunc"/> must be non-null, and the implementation of <see cref="IAudioTranscriptionClient.TranscribeAsync"/>
+    /// will use <paramref name="transcribeStreamingFunc"/> for the implementation.
+    /// </param>
+    /// <param name="transcribeStreamingFunc">
+    /// A delegate that provides the implementation for <see cref="IAudioTranscriptionClient.TranscribeStreamingAsync"/>. When <see langword="null"/>,
+    /// <paramref name="transcribeFunc"/> must be non-null, and the implementation of <see cref="IAudioTranscriptionClient.TranscribeStreamingAsync"/>
+    /// will use <paramref name="transcribeFunc"/> for the implementation.
+    /// </param>
+    /// <returns>The updated <see cref="AudioTranscriptionClientBuilder"/> instance.</returns>
+    /// <remarks>
+    /// One or both delegates may be provided. If both are provided, they will be used for their respective methods:
+    /// <paramref name="transcribeFunc"/> will provide the implementation of <see cref="IAudioTranscriptionClient.TranscribeAsync"/>, and
+    /// <paramref name="transcribeStreamingFunc"/> will provide the implementation of <see cref="IAudioTranscriptionClient.TranscribeStreamingAsync"/>.
+    /// If only one of the delegates is provided, it will be used for both methods. That means that if <paramref name="transcribeFunc"/>
+    /// is supplied without <paramref name="transcribeStreamingFunc"/>, the implementation of <see cref="IAudioTranscriptionClient.TranscribeStreamingAsync"/>
+    /// will employ limited streaming, as it will be operating on the batch output produced by <paramref name="transcribeFunc"/>. And if
+    /// <paramref name="transcribeStreamingFunc"/> is supplied without <paramref name="transcribeFunc"/>, the implementation of
+    /// <see cref="IAudioTranscriptionClient.TranscribeAsync"/> will be implemented by combining the updates from <paramref name="transcribeStreamingFunc"/>.
+    /// </remarks>
+    /// <exception cref="ArgumentNullException">Both <paramref name="transcribeFunc"/> and <paramref name="transcribeStreamingFunc"/> are <see langword="null"/>.</exception>
+    public AudioTranscriptionClientBuilder Use(
+        Func<IList<IAsyncEnumerable<DataContent>>, AudioTranscriptionOptions?, IAudioTranscriptionClient, CancellationToken, Task<AudioTranscriptionCompletion>>? transcribeFunc,
+        Func<IList<IAsyncEnumerable<DataContent>>, AudioTranscriptionOptions?, IAudioTranscriptionClient, CancellationToken,
+            IAsyncEnumerable<StreamingAudioTranscriptionUpdate>>? transcribeStreamingFunc)
+    {
+        AnonymousDelegatingAudioTranscriptionClient.ThrowIfBothDelegatesNull(transcribeFunc, transcribeStreamingFunc);
+
+        return Use((innerClient, _) => new AnonymousDelegatingAudioTranscriptionClient(innerClient, transcribeFunc, transcribeStreamingFunc));
+    }
+}

test/Libraries/Microsoft.Extensions.AI.Integration.Tests/AudioTranscriptionClientIntegrationTests.cs

@@ -100,13 +100,13 @@ public virtual async Task TranscribeStreamingAsync_MultipleStreamingResponseChoi
             }
         }
 
-        string responseText = firstSb.ToString();
-        Assert.Contains("finally", responseText, StringComparison.OrdinalIgnoreCase);
-        Assert.Contains("gym", responseText, StringComparison.OrdinalIgnoreCase);
+        string firstTranscription = firstSb.ToString();
+        Assert.Contains("finally", firstTranscription, StringComparison.OrdinalIgnoreCase);
+        Assert.Contains("gym", firstTranscription, StringComparison.OrdinalIgnoreCase);
 
-        responseText = secondSb.ToString();
-        Assert.Contains("who would", responseText, StringComparison.OrdinalIgnoreCase);
-        Assert.Contains("go for", responseText, StringComparison.OrdinalIgnoreCase);
+        string secondTranscription = secondSb.ToString();
+        Assert.Contains("who would", secondTranscription, StringComparison.OrdinalIgnoreCase);
+        Assert.Contains("go for", secondTranscription, StringComparison.OrdinalIgnoreCase);
     }
 
     private static Stream GetAudioStream(string fileName)

test/Libraries/Microsoft.Extensions.AI.OpenAI.Tests/OpenAIAudioTranscriptionClientIntegrationTests.cs

@@ -0,0 +1,11 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+
+namespace Microsoft.Extensions.AI;
+
+public class OpenAIAudioTranscriptionClientIntegrationTests : AudioTranscriptionClientIntegrationTests
+{
+    protected override IAudioTranscriptionClient? CreateClient()
+        => IntegrationTestHelpers.GetOpenAIClient()
+        ?.AsAudioTranscriptionClient(TestRunnerConfiguration.Instance["OpenAI:AudioTranscriptionModel"] ?? "whisper-1");
+}