82 instantiations of ChatResponseUpdate
Microsoft.Extensions.AI (1)
ChatCompletion\FunctionInvokingChatClient.cs (1)
390var toolResultUpdate = new ChatResponseUpdate
Microsoft.Extensions.AI.Abstractions (2)
ChatCompletion\ChatResponse.cs (2)
113extra = new ChatResponseUpdate 131updates[i] = new ChatResponseUpdate
Microsoft.Extensions.AI.Abstractions.Tests (33)
ChatCompletion\ChatClientExtensionsTests.cs (1)
146return YieldAsync([new ChatResponseUpdate(ChatRole.Assistant, "world")]);
ChatCompletion\ChatResponseUpdateExtensionsTests.cs (26)
31new(ChatRole.Assistant, "Hello") { ResponseId = "someResponse", MessageId = "12345", CreatedAt = new DateTimeOffset(1, 2, 3, 4, 5, 6, TimeSpan.Zero), ModelId = "model123" }, 32new(new("human"), ", ") { AuthorName = "Someone", AdditionalProperties = new() { ["a"] = "b" } }, 33new(null, "world!") { CreatedAt = new DateTimeOffset(2, 2, 3, 4, 5, 6, TimeSpan.Zero), ConversationId = "123", AdditionalProperties = new() { ["c"] = "d" } }, 35new() { Contents = [new UsageContent(new() { InputTokenCount = 1, OutputTokenCount = 2 })] }, 36new() { Contents = [new UsageContent(new() { InputTokenCount = 4, OutputTokenCount = 5 })] }, 107updates.Add(new(null, text)); 128updates.Add(new() { Contents = [new DataContent("data:image/png;base64,aGVsbG8=")] }); 155new(null, "A"), 156new(null, "B"), 157new(null, "C"), 158new() { Contents = [new TextReasoningContent("D")] }, 159new() { Contents = [new TextReasoningContent("E")] }, 160new() { Contents = [new TextReasoningContent("F")] }, 161new(null, "G"), 162new(null, "H"), 163new() { Contents = [new TextReasoningContent("I")] }, 164new() { Contents = [new TextReasoningContent("J")] }, 165new(null, "K"), 166new() { Contents = [new TextReasoningContent("L")] }, 167new(null, "M"), 168new(null, "N"), 169new() { Contents = [new TextReasoningContent("O")] }, 170new() { Contents = [new TextReasoningContent("P")] }, 191new(null, "Hello, "), 192new(null, "world!"), 193new() { Contents = [new UsageContent(new() { TotalTokenCount = 42 })] },
ChatCompletion\ChatResponseUpdateTests.cs (4)
16ChatResponseUpdate update = new(); 33ChatResponseUpdate update = new(); 87ChatResponseUpdate update = new() 115ChatResponseUpdate original = new()
ChatCompletion\DelegatingChatClientTests.cs (2)
61new(ChatRole.User, "Message 1"), 62new(ChatRole.User, "Message 2")
Microsoft.Extensions.AI.AzureAIInference (2)
AzureAIInferenceChatClient.cs (2)
165ChatResponseUpdate responseUpdate = new() 227var responseUpdate = new ChatResponseUpdate
Microsoft.Extensions.AI.Evaluation.Safety (1)
ContentSafetyChatClient.cs (1)
111yield return new ChatResponseUpdate(ChatRole.Assistant, annotationResult)
Microsoft.Extensions.AI.Ollama (1)
OllamaChatClient.cs (1)
168ChatResponseUpdate update = new()
Microsoft.Extensions.AI.OpenAI (11)
OpenAIAssistantChatClient.cs (3)
174ChatResponseUpdate ruUpdate = new() 209yield return new(mcu.Role == MessageRole.User ? ChatRole.User : ChatRole.Assistant, mcu.Text) 220yield return new ChatResponseUpdate
OpenAIChatClient.cs (2)
301ChatResponseUpdate responseUpdate = new() 364ChatResponseUpdate responseUpdate = new()
OpenAIResponseChatClient.cs (6)
181yield return new() 219yield return new ChatResponseUpdate(lastRole, outputTextDeltaUpdate.Delta) 254yield return new ChatResponseUpdate(lastRole, [fci]) 271yield return new ChatResponseUpdate 292yield return new ChatResponseUpdate 306yield return new ChatResponseUpdate
Microsoft.Extensions.AI.Tests (30)
ChatCompletion\ConfigureOptionsChatClientTests.cs (1)
38var expectedUpdates = Enumerable.Range(0, 3).Select(i => new ChatResponseUpdate()).ToArray();
ChatCompletion\DistributedCachingChatClientTest.cs (16)
249new() 262new() 267new() 313new(ChatRole.Assistant, "This"), 314new(ChatRole.Assistant, " becomes one chunk"), 315new() { Role = ChatRole.Assistant, Contents = [new FunctionCallContent("callId1", "separator")] }, 316new(ChatRole.Assistant, "... and this"), 317new(ChatRole.Assistant, " becomes another"), 318new(ChatRole.Assistant, " one."), 368new() { Role = ChatRole.Assistant, Contents = [new TextContent("Hello")] }, 369new() { Role = ChatRole.Assistant, Contents = [new TextContent(" world, ")] }, 370new() 381new() 436new(ChatRole.Assistant, "Chunk 1"), 484() => new(ChatRole.Assistant, "Chunk 1"), 523[() => new(ChatRole.Assistant, "A good result")]);
ChatCompletion\FunctionInvokingChatClientTests.cs (3)
597new() { Contents = [new FunctionCallContent("callId1", "Func1", new Dictionary<string, object?> { ["text"] = "Input 1" })] }, 598new() { Contents = [new FunctionCallContent("callId2", "Func1", new Dictionary<string, object?> { ["text"] = "Input 2" })] } 603updates = [new() { Contents = [new TextContent("OK bye")] }];
ChatCompletion\LoggingChatClientTests.cs (2)
108yield return new(ChatRole.Assistant, "blue "); 109yield return new(ChatRole.Assistant, "whale");
ChatCompletion\OpenTelemetryChatClientTests.cs (3)
72yield return new ChatResponseUpdate(ChatRole.Assistant, text) 78yield return new ChatResponseUpdate 83yield return new ChatResponseUpdate
ChatCompletion\UseDelegateChatClientTests.cs (5)
51return YieldUpdates(new ChatResponseUpdate(null, "world")); 133return YieldUpdates(new ChatResponseUpdate(null, "hello")); 154yield return new(null, " world"); 193return YieldUpdates(new ChatResponseUpdate(null, "streaming hello")); 225yield return new(null, " world (streaming)");
Microsoft.ML.GenAI.Core (1)
CausalLMPipelineChatClient.cs (1)
73yield return new(ChatRole.Assistant, output)
200 references to ChatResponseUpdate
Microsoft.Extensions.AI (44)
ChatCompletion\AnonymousDelegatingChatClient.cs (10)
31private readonly Func<IEnumerable<ChatMessage>, ChatOptions?, IChatClient, CancellationToken, IAsyncEnumerable<ChatResponseUpdate>>? _getStreamingResponseFunc; 80Func<IEnumerable<ChatMessage>, ChatOptions?, IChatClient, CancellationToken, IAsyncEnumerable<ChatResponseUpdate>>? getStreamingResponseFunc) 129public override IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync( 136var updates = Channel.CreateBounded<ChatResponseUpdate>(1); 146await foreach (var update in InnerClient.GetStreamingResponseAsync(messages, options, cancellationToken)) 167static async IAsyncEnumerable<ChatResponseUpdate> ReadAllAsync( 168ChannelReader<ChatResponseUpdate> channel, [EnumeratorCancellation] CancellationToken cancellationToken) 172while (channel.TryRead(out var update)) 189static async IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsyncViaGetResponseAsync(Task<ChatResponse> task) 192foreach (var update in response.ToChatResponseUpdates())
ChatCompletion\CachingChatClient.cs (12)
77public override IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync( 87private async IAsyncEnumerable<ChatResponseUpdate> GetCachedStreamingResponseAsync( 100foreach (var chunk in chatResponse.ToChatResponseUpdates()) 108List<ChatResponseUpdate> capturedItems = []; 109await foreach (var chunk in base.GetStreamingResponseAsync(messages, options, cancellationToken)) 126foreach (var chunk in existingChunks) 135List<ChatResponseUpdate> capturedItems = []; 136await foreach (var chunk in base.GetStreamingResponseAsync(messages, options, cancellationToken)) 166/// Returns a previously cached list of <see cref="ChatResponseUpdate"/> values, if available. 173protected abstract Task<IReadOnlyList<ChatResponseUpdate>?> ReadCacheStreamingAsync(string key, CancellationToken cancellationToken); 188/// Stores a list of <see cref="ChatResponseUpdate"/> values in the underlying cache. 197protected abstract Task WriteCacheStreamingAsync(string key, IReadOnlyList<ChatResponseUpdate> value, CancellationToken cancellationToken);
ChatCompletion\ChatClientBuilder.cs (1)
144Func<IEnumerable<ChatMessage>, ChatOptions?, IChatClient, CancellationToken, IAsyncEnumerable<ChatResponseUpdate>>? getStreamingResponseFunc)
ChatCompletion\ConfigureOptionsChatClient.cs (2)
42public override async IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync( 45await foreach (var update in base.GetStreamingResponseAsync(messages, Configure(options), cancellationToken))
ChatCompletion\DistributedCachingChatClient.cs (6)
24/// the object models used by <see cref="ChatMessage"/>, <see cref="ChatOptions"/>, <see cref="ChatResponse"/>, <see cref="ChatResponseUpdate"/>, 74protected override async Task<IReadOnlyList<ChatResponseUpdate>?> ReadCacheStreamingAsync(string key, CancellationToken cancellationToken) 81return (IReadOnlyList<ChatResponseUpdate>?)JsonSerializer.Deserialize(existingJson, _jsonSerializerOptions.GetTypeInfo(typeof(IReadOnlyList<ChatResponseUpdate>))); 99protected override async Task WriteCacheStreamingAsync(string key, IReadOnlyList<ChatResponseUpdate> value, CancellationToken cancellationToken) 105var newJson = JsonSerializer.SerializeToUtf8Bytes(value, _jsonSerializerOptions.GetTypeInfo(typeof(IReadOnlyList<ChatResponseUpdate>)));
ChatCompletion\DistributedCachingChatClientBuilderExtensions.cs (1)
29/// the object models used by <see cref="ChatMessage"/>, <see cref="ChatOptions"/>, <see cref="ChatResponse"/>, <see cref="ChatResponseUpdate"/>,
ChatCompletion\FunctionInvokingChatClient.cs (5)
304public override async IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync( 323List<ChatResponseUpdate> updates = []; // updates from the current response 331await foreach (var update in base.GetStreamingResponseAsync(messages, options, cancellationToken)) 335Throw.InvalidOperationException($"The inner {nameof(IChatClient)} streamed a null {nameof(ChatResponseUpdate)}."); 390var toolResultUpdate = new ChatResponseUpdate
ChatCompletion\LoggingChatClient.cs (3)
100public override async IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync( 115IAsyncEnumerator<ChatResponseUpdate> e; 133ChatResponseUpdate? update = null;
ChatCompletion\OpenTelemetryChatClient.cs (4)
163public override async IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync( 175IAsyncEnumerable<ChatResponseUpdate> updates; 187List<ChatResponseUpdate> trackedUpdates = []; 193ChatResponseUpdate update;
Microsoft.Extensions.AI.Abstractions (42)
ChatCompletion\ChatClientExtensions.cs (2)
131public static IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync( 151public static IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync(
ChatCompletion\ChatResponse.cs (5)
106/// <summary>Creates an array of <see cref="ChatResponseUpdate" /> instances that represent this <see cref="ChatResponse" />.</summary> 107/// <returns>An array of <see cref="ChatResponseUpdate" /> instances that may be used to represent this <see cref="ChatResponse" />.</returns> 108public ChatResponseUpdate[] ToChatResponseUpdates() 110ChatResponseUpdate? extra = null; 125var updates = new ChatResponseUpdate[messageCount + (extra is not null ? 1 : 0)];
ChatCompletion\ChatResponseExtensions.cs (23)
18/// Provides extension methods for working with <see cref="ChatResponse"/> and <see cref="ChatResponseUpdate"/> instances. 47/// <param name="updates">The <see cref="ChatResponseUpdate"/> instances to convert to messages and add to the list.</param> 52/// method may use <see cref="ChatResponseUpdate.MessageId"/> to determine message boundaries, as well as coalesce 56public static void AddMessages(this IList<ChatMessage> list, IEnumerable<ChatResponseUpdate> updates) 61if (updates is ICollection<ChatResponseUpdate> { Count: 0 }) 71/// <param name="update">The <see cref="ChatResponseUpdate"/> instance to convert to a message and add to the list.</param> 76/// If the <see cref="ChatResponseUpdate"/> has no content, or all its content gets excluded by <paramref name="filter"/>, then 79public static void AddMessages(this IList<ChatMessage> list, ChatResponseUpdate update, Func<AIContent, bool>? filter = null) 98/// <param name="updates">The <see cref="ChatResponseUpdate"/> instances to convert to messages and add to the list.</param> 105/// method may use <see cref="ChatResponseUpdate.MessageId"/> to determine message boundaries, as well as coalesce 110this IList<ChatMessage> list, IAsyncEnumerable<ChatResponseUpdate> updates, CancellationToken cancellationToken = default) 118IList<ChatMessage> list, IAsyncEnumerable<ChatResponseUpdate> updates, CancellationToken cancellationToken) => 122/// <summary>Combines <see cref="ChatResponseUpdate"/> instances into a single <see cref="ChatResponse"/>.</summary> 128/// <see cref="ChatMessage"/> instances. This includes using <see cref="ChatResponseUpdate.MessageId"/> to determine 133this IEnumerable<ChatResponseUpdate> updates) 139foreach (var update in updates) 149/// <summary>Combines <see cref="ChatResponseUpdate"/> instances into a single <see cref="ChatResponse"/>.</summary> 156/// <see cref="ChatMessage"/> instances. This includes using <see cref="ChatResponseUpdate.MessageId"/> to determine 161this IAsyncEnumerable<ChatResponseUpdate> updates, CancellationToken cancellationToken = default) 168IAsyncEnumerable<ChatResponseUpdate> updates, CancellationToken cancellationToken) 172await foreach (var update in updates.WithCancellation(cancellationToken).ConfigureAwait(false)) 249/// <summary>Processes the <see cref="ChatResponseUpdate"/>, incorporating its contents into <paramref name="response"/>.</summary> 252private static void ProcessUpdate(ChatResponseUpdate update, ChatResponse response)
ChatCompletion\ChatResponseUpdate.cs (8)
17/// <see cref="ChatResponseUpdate"/> is so named because it represents updates 22/// The relationship between <see cref="ChatResponse"/> and <see cref="ChatResponseUpdate"/> is 41/// <summary>Initializes a new instance of the <see cref="ChatResponseUpdate"/> class.</summary> 47/// <summary>Initializes a new instance of the <see cref="ChatResponseUpdate"/> class.</summary> 55/// <summary>Initializes a new instance of the <see cref="ChatResponseUpdate"/> class.</summary> 91/// If a <see cref="ChatResponseUpdate"/> is created to represent some underlying object from another object 112/// This value is used when <see cref="ChatResponseExtensions.ToChatResponseAsync(IAsyncEnumerable{ChatResponseUpdate}, System.Threading.CancellationToken)"/> 113/// groups <see cref="ChatResponseUpdate"/> instances into <see cref="ChatMessage"/> instances.
ChatCompletion\DelegatingChatClient.cs (1)
47public virtual IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync(
ChatCompletion\IChatClient.cs (1)
54IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync(
Utilities\AIJsonUtilities.Defaults.cs (2)
81[JsonSerializable(typeof(ChatResponseUpdate))] 82[JsonSerializable(typeof(IReadOnlyList<ChatResponseUpdate>))]
Microsoft.Extensions.AI.Abstractions.Tests (24)
ChatCompletion\ChatClientExtensionsTests.cs (4)
151await foreach (var update in client.GetStreamingResponseAsync("hello", expectedOptions, cts.Token)) 161private static async IAsyncEnumerable<ChatResponseUpdate> YieldAsync(params ChatResponseUpdate[] updates) 164foreach (var update in updates)
ChatCompletion\ChatResponseTests.cs (3)
139ChatResponseUpdate[] updates = response.ToChatResponseUpdates(); 143ChatResponseUpdate update0 = updates[0]; 152ChatResponseUpdate update1 = updates[1];
ChatCompletion\ChatResponseUpdateExtensionsTests.cs (8)
21Assert.Throws<ArgumentNullException>("updates", () => ((List<ChatResponseUpdate>)null!).ToChatResponse()); 29ChatResponseUpdate[] updates = 92List<ChatResponseUpdate> updates = []; 153ChatResponseUpdate[] updates = 189ChatResponseUpdate[] updates = 206private static async IAsyncEnumerable<ChatResponseUpdate> YieldAsync(IEnumerable<ChatResponseUpdate> updates) 208foreach (ChatResponseUpdate update in updates)
ChatCompletion\ChatResponseUpdateTests.cs (5)
16ChatResponseUpdate update = new(); 33ChatResponseUpdate update = new(); 87ChatResponseUpdate update = new() 115ChatResponseUpdate original = new() 137ChatResponseUpdate? result = JsonSerializer.Deserialize(json, TestJsonSerializerContext.Default.ChatResponseUpdate);
ChatCompletion\DelegatingChatClientTests.cs (1)
59ChatResponseUpdate[] expectedResults =
TestChatClient.cs (2)
22public Func<IEnumerable<ChatMessage>, ChatOptions?, CancellationToken, IAsyncEnumerable<ChatResponseUpdate>>? GetStreamingResponseAsyncCallback { get; set; } 32public IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync(IEnumerable<ChatMessage> messages, ChatOptions? options = null, CancellationToken cancellationToken = default)
TestJsonSerializerContext.cs (1)
18[JsonSerializable(typeof(ChatResponseUpdate))]
Microsoft.Extensions.AI.AzureAIInference (3)
AzureAIInferenceChatClient.cs (3)
140public async IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync( 165ChatResponseUpdate responseUpdate = new() 227var responseUpdate = new ChatResponseUpdate
Microsoft.Extensions.AI.AzureAIInference.Tests (7)
AzureAIInferenceChatClientTests.cs (7)
221List<ChatResponseUpdate> updates = []; 222await foreach (var update in client.GetStreamingResponseAsync(messages, new() 272await foreach (var update in client.GetStreamingResponseAsync("hello", new ChatOptions 453await foreach (var update in client.GetStreamingResponseAsync("hello", chatOptions)) 611await foreach (var update in client.GetStreamingResponseAsync("hello", chatOptions)) 1335List<ChatResponseUpdate> updates = []; 1336await foreach (var update in client.GetStreamingResponseAsync("How old is Alice?", new()
Microsoft.Extensions.AI.Evaluation.Reporting (6)
ResponseCachingChatClient.cs (3)
58protected override async Task<IReadOnlyList<ChatResponseUpdate>?> ReadCacheStreamingAsync( 64IReadOnlyList<ChatResponseUpdate>? updates = 108IReadOnlyList<ChatResponseUpdate> value,
SimpleChatClient.cs (3)
51public override async IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync( 56List<ChatResponseUpdate>? updates = null; 61await foreach (ChatResponseUpdate update in
Microsoft.Extensions.AI.Evaluation.Safety (2)
ContentSafetyChatClient.cs (2)
94public async IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync( 120await foreach (var update in
Microsoft.Extensions.AI.Integration.Tests (16)
CallCountingChatClient.cs (1)
26public override IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync(
ChatClientIntegrationTests.cs (9)
106await foreach (var chunk in _chatClient.GetStreamingResponseAsync(chatHistory)) 141List<ChatResponseUpdate> chunks = []; 142await foreach (var chunk in response) 271await foreach (var chunk in response) 609await foreach (var update in chatClient.GetStreamingResponseAsync([message])) 618await foreach (var update in chatClient.GetStreamingResponseAsync([message])) 629await foreach (var update in chatClient.GetStreamingResponseAsync([message])) 787await foreach (var update in chatClient.GetStreamingResponseAsync("What's the biggest animal?")) 838await foreach (var update in chatClient.GetStreamingResponseAsync(
PromptBasedFunctionCallingChatClient.cs (2)
137public override async IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync( 141foreach (var update in response.ToChatResponseUpdates())
ReducingChatClientTests.cs (2)
84public override async IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync( 89await foreach (var update in base.GetStreamingResponseAsync(messages, options, cancellationToken).ConfigureAwait(false))
test\Libraries\Microsoft.Extensions.AI.Abstractions.Tests\TestChatClient.cs (2)
22public Func<IEnumerable<ChatMessage>, ChatOptions?, CancellationToken, IAsyncEnumerable<ChatResponseUpdate>>? GetStreamingResponseAsyncCallback { get; set; } 32public IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync(IEnumerable<ChatMessage> messages, ChatOptions? options = null, CancellationToken cancellationToken = default)
Microsoft.Extensions.AI.Ollama (2)
OllamaChatClient.cs (2)
126public async IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync( 168ChatResponseUpdate update = new()
Microsoft.Extensions.AI.Ollama.Tests (2)
OllamaChatClientTests.cs (2)
174List<ChatResponseUpdate> updates = []; 180await foreach (var update in streamingResponse)
Microsoft.Extensions.AI.OpenAI (7)
OpenAIAssistantChatClient.cs (2)
83public async IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync( 174ChatResponseUpdate ruUpdate = new()
OpenAIChatClient.cs (4)
84public IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync( 278private static async IAsyncEnumerable<ChatResponseUpdate> FromOpenAIStreamingChatCompletionAsync( 301ChatResponseUpdate responseUpdate = new() 364ChatResponseUpdate responseUpdate = new()
OpenAIResponseChatClient.cs (1)
151public async IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync(
Microsoft.Extensions.AI.OpenAI.Tests (8)
OpenAIChatClientTests.cs (6)
238List<ChatResponseUpdate> updates = []; 239await foreach (var update in client.GetStreamingResponseAsync("hello", new() 436await foreach (var update in client.GetStreamingResponseAsync("hello", chatOptions)) 595await foreach (var update in client.GetStreamingResponseAsync("hello", chatOptions)) 1266List<ChatResponseUpdate> updates = []; 1267await foreach (var update in client.GetStreamingResponseAsync("How old is Alice?", new()
OpenAIResponseClientTests.cs (2)
254List<ChatResponseUpdate> updates = []; 255await foreach (var update in client.GetStreamingResponseAsync("hello", new()
Microsoft.Extensions.AI.Tests (32)
ChatCompletion\ConfigureOptionsChatClientTests.cs (3)
89static async IAsyncEnumerable<ChatResponseUpdate> YieldUpdates(ChatResponseUpdate[] updates) 91foreach (var update in updates)
ChatCompletion\DistributedCachingChatClientTest.cs (13)
247List<ChatResponseUpdate> actualUpdate = 260List<ChatResponseUpdate> expectedCachedResponse = 311List<ChatResponseUpdate> expectedResponse = 344ChatResponseUpdate update = Assert.Single(await ToListAsync(result2)); 366List<ChatResponseUpdate> expectedResponse = 416var item = Assert.Single(items); 434List<ChatResponseUpdate> expectedResponse = 482return ToAsyncEnumerableAsync<ChatResponseUpdate>(Task.CompletedTask, 521return ToAsyncEnumerableAsync<ChatResponseUpdate>( 787private static async Task AssertResponsesEqualAsync(IReadOnlyList<ChatResponseUpdate> expected, IAsyncEnumerable<ChatResponseUpdate> actual) 791foreach (var expectedItem in expected) 795var actualItem = actualEnumerator.Current;
ChatCompletion\FunctionInvokingChatClientTests.cs (2)
591List<ChatResponseUpdate> updates; 606foreach (var update in updates)
ChatCompletion\LoggingChatClientTests.cs (2)
105static async IAsyncEnumerable<ChatResponseUpdate> GetUpdatesAsync() 117await foreach (var update in client.GetStreamingResponseAsync(
ChatCompletion\OpenTelemetryChatClientTests.cs (2)
64async static IAsyncEnumerable<ChatResponseUpdate> CallbackAsync( 139await foreach (var update in chatClient.GetStreamingResponseAsync(messages, options))
ChatCompletion\UseDelegateChatClientTests.cs (7)
146static async IAsyncEnumerable<ChatResponseUpdate> Impl( 149await foreach (var update in innerClient.GetStreamingResponseAsync(messages, options, cancellationToken)) 217static async IAsyncEnumerable<ChatResponseUpdate> Impl( 220await foreach (var update in innerClient.GetStreamingResponseAsync(messages, options, cancellationToken)) 239private static async IAsyncEnumerable<ChatResponseUpdate> YieldUpdates(params ChatResponseUpdate[] updates) 241foreach (var update in updates)
test\Libraries\Microsoft.Extensions.AI.Abstractions.Tests\TestChatClient.cs (2)
22public Func<IEnumerable<ChatMessage>, ChatOptions?, CancellationToken, IAsyncEnumerable<ChatResponseUpdate>>? GetStreamingResponseAsyncCallback { get; set; } 32public IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync(IEnumerable<ChatMessage> messages, ChatOptions? options = null, CancellationToken cancellationToken = default)
TestJsonSerializerContext.cs (1)
15[JsonSerializable(typeof(IReadOnlyList<ChatResponseUpdate>))]
Microsoft.ML.GenAI.Core (1)
CausalLMPipelineChatClient.cs (1)
57public virtual async IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync(
Microsoft.ML.GenAI.LLaMA (1)
Llama3CausalLMChatClient.cs (1)
46public override IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync(
Microsoft.ML.GenAI.Phi (1)
Phi3\Phi3CausalLMChatClient.cs (1)
51public override IAsyncEnumerable<ChatResponseUpdate> GetStreamingResponseAsync(
Microsoft.ML.GenAI.Samples (2)
MEAI\Llama3_1.cs (1)
49await foreach (var response in client.GetStreamingResponseAsync([chatMessage]))
MEAI\Phi3.cs (1)
39await foreach (var response in client.GetStreamingResponseAsync([chatMessage]))