8 implementations of CompleteStreamingAsync
Microsoft.Extensions.AI.Abstractions (1)
ChatCompletion\DelegatingChatClient.cs (1)
60public virtual IAsyncEnumerable<StreamingChatCompletionUpdate> CompleteStreamingAsync(IList<ChatMessage> chatMessages, ChatOptions? options = null, CancellationToken cancellationToken = default)
Microsoft.Extensions.AI.Abstractions.Tests (1)
TestChatClient.cs (1)
34public IAsyncEnumerable<StreamingChatCompletionUpdate> CompleteStreamingAsync(IList<ChatMessage> chatMessages, ChatOptions? options = null, CancellationToken cancellationToken = default)
Microsoft.Extensions.AI.AzureAIInference (1)
AzureAIInferenceChatClient.cs (1)
147public async IAsyncEnumerable<StreamingChatCompletionUpdate> CompleteStreamingAsync(
Microsoft.Extensions.AI.Integration.Tests (1)
test\Libraries\Microsoft.Extensions.AI.Abstractions.Tests\TestChatClient.cs (1)
34public IAsyncEnumerable<StreamingChatCompletionUpdate> CompleteStreamingAsync(IList<ChatMessage> chatMessages, ChatOptions? options = null, CancellationToken cancellationToken = default)
Microsoft.Extensions.AI.Ollama (1)
OllamaChatClient.cs (1)
110public async IAsyncEnumerable<StreamingChatCompletionUpdate> CompleteStreamingAsync(
Microsoft.Extensions.AI.OpenAI (1)
OpenAIChatClient.cs (1)
116public IAsyncEnumerable<StreamingChatCompletionUpdate> CompleteStreamingAsync(
Microsoft.Extensions.AI.Tests (1)
test\Libraries\Microsoft.Extensions.AI.Abstractions.Tests\TestChatClient.cs (1)
34public IAsyncEnumerable<StreamingChatCompletionUpdate> CompleteStreamingAsync(IList<ChatMessage> chatMessages, ChatOptions? options = null, CancellationToken cancellationToken = default)
Microsoft.ML.GenAI.Core (1)
CausalLMPipelineChatClient.cs (1)
57public virtual async IAsyncEnumerable<StreamingChatCompletionUpdate> CompleteStreamingAsync(
25 references to CompleteStreamingAsync
Microsoft.Extensions.AI (12)
ChatCompletion\AnonymousDelegatingChatClient.cs (3)
141await foreach (var update in InnerClient.CompleteStreamingAsync(chatMessages, options, cancellationToken).ConfigureAwait(false)) 196/// Represents a method used to call <see cref="IChatClient.CompleteAsync"/> or <see cref="IChatClient.CompleteStreamingAsync"/>. 202/// <see cref="IChatClient.CompleteStreamingAsync"/>. It should be invoked to continue the pipeline. It accepts
ChatCompletion\CachingChatClient.cs (2)
144/// This is used when there is a call to <see cref="IChatClient.CompleteStreamingAsync(IList{ChatMessage}, ChatOptions?, CancellationToken)"/>. 163/// This is used when there is a call to <see cref="IChatClient.CompleteStreamingAsync(IList{ChatMessage}, ChatOptions?, CancellationToken)"/>.
ChatCompletion\ChatClientBuilder.cs (7)
84/// an implementation for both <see cref="IChatClient.CompleteAsync"/> and <see cref="IChatClient.CompleteStreamingAsync"/>. 88/// <see cref="IChatClient.CompleteStreamingAsync"/>. In addition to the arguments for the operation, it's 107/// an implementation for both <see cref="IChatClient.CompleteAsync"/> and <see cref="IChatClient.CompleteStreamingAsync"/>. 115/// A delegate that provides the implementation for <see cref="IChatClient.CompleteStreamingAsync"/>. When <see langword="null"/>, 116/// <paramref name="completeFunc"/> must be non-null, and the implementation of <see cref="IChatClient.CompleteStreamingAsync"/> 123/// <paramref name="completeStreamingFunc"/> will provide the implementation of <see cref="IChatClient.CompleteStreamingAsync"/>. 125/// is supplied without <paramref name="completeStreamingFunc"/>, the implementation of <see cref="IChatClient.CompleteStreamingAsync"/>
Microsoft.Extensions.AI.Abstractions (2)
ChatCompletion\DelegatingChatClient.cs (1)
62return InnerClient.CompleteStreamingAsync(chatMessages, options, cancellationToken);
ChatCompletion\IChatClient.cs (1)
19/// <see cref="CompleteStreamingAsync"/>, such as by adding additional messages to the messages list or configuring the options
Microsoft.Extensions.AI.AzureAIInference.Tests (1)
AzureAIInferenceChatClientTests.cs (1)
221await foreach (var update in client.CompleteStreamingAsync(chatMessages, new()
Microsoft.Extensions.AI.Integration.Tests (1)
ChatClientIntegrationTests.cs (1)
84await foreach (var chunk in _chatClient.CompleteStreamingAsync(chatHistory))
Microsoft.Extensions.AI.Tests (9)
ChatCompletion\ConfigureOptionsChatClientTests.cs (1)
80await using var e = client.CompleteStreamingAsync(Array.Empty<ChatMessage>(), providedOptions, cts.Token).GetAsyncEnumerator();
ChatCompletion\FunctionInvokingChatClientTests.cs (2)
379Validate(await Assert.ThrowsAsync<InvalidOperationException>(() => service.CompleteStreamingAsync(chat, options).ToChatCompletionAsync())); 678var result = await service.CompleteStreamingAsync(chat, options, cts.Token).ToChatCompletionAsync();
ChatCompletion\UseDelegateChatClientTests.cs (6)
79completion = await client.CompleteStreamingAsync(expectedMessages, expectedOptions, expectedCts.Token).ToChatCompletionAsync(); 121completion = await client.CompleteStreamingAsync(expectedMessages, expectedOptions, expectedCts.Token).ToChatCompletionAsync(); 157await foreach (var update in innerClient.CompleteStreamingAsync(chatMessages, options, cancellationToken)) 172completion = await client.CompleteStreamingAsync(expectedMessages, expectedOptions, expectedCts.Token).ToChatCompletionAsync(); 228await foreach (var update in innerClient.CompleteStreamingAsync(chatMessages, options, cancellationToken)) 243completion = await client.CompleteStreamingAsync(expectedMessages, expectedOptions, expectedCts.Token).ToChatCompletionAsync();