RealtimeServerMessage

5 types derived from RealtimeServerMessage

Microsoft.Extensions.AI.Abstractions (5)

Realtime\ErrorRealtimeServerMessage.cs (1)

16public class ErrorRealtimeServerMessage : RealtimeServerMessage

Realtime\InputAudioTranscriptionRealtimeServerMessage.cs (1)

16public class InputAudioTranscriptionRealtimeServerMessage : RealtimeServerMessage

Realtime\OutputTextAudioRealtimeServerMessage.cs (1)

13public class OutputTextAudioRealtimeServerMessage : RealtimeServerMessage

Realtime\ResponseCreatedRealtimeServerMessage.cs (1)

30public class ResponseCreatedRealtimeServerMessage : RealtimeServerMessage

Realtime\ResponseOutputItemRealtimeServerMessage.cs (1)

24public class ResponseOutputItemRealtimeServerMessage : RealtimeServerMessage

12 instantiations of RealtimeServerMessage

Microsoft.Extensions.AI.Abstractions.Tests (2)

Realtime\RealtimeServerMessageTests.cs (2)

16var message = new RealtimeServerMessage(); 27var message = new RealtimeServerMessage

Microsoft.Extensions.AI.OpenAI (2)

OpenAIRealtimeClientSession.cs (2)

809_ => new RealtimeServerMessage 845return new RealtimeServerMessage

Microsoft.Extensions.AI.Tests (8)

Realtime\FunctionInvokingRealtimeClientTests.cs (4)

66new() { Type = RealtimeServerMessageType.ResponseCreated, MessageId = "evt_001" }, 67new() { Type = RealtimeServerMessageType.ResponseDone, MessageId = "evt_002" }, 379new RealtimeServerMessage { Type = RealtimeServerMessageType.ResponseDone, MessageId = "should_not_reach" }, 603new RealtimeServerMessage { Type = RealtimeServerMessageType.ResponseDone, MessageId = "should_not_reach" },

Realtime\LoggingRealtimeClientTests.cs (2)

166yield return new RealtimeServerMessage { Type = RealtimeServerMessageType.OutputTextDelta, MessageId = "event-1" }; 167yield return new RealtimeServerMessage { Type = RealtimeServerMessageType.OutputAudioDelta, MessageId = "event-2" };

Realtime\OpenTelemetryRealtimeClientTests.cs (2)

56yield return new RealtimeServerMessage { Type = RealtimeServerMessageType.ResponseCreated, MessageId = "evt_001" }; 218yield return new RealtimeServerMessage { Type = RealtimeServerMessageType.ResponseCreated };

88 references to RealtimeServerMessage

Microsoft.Extensions.AI (11)

Realtime\FunctionInvokingRealtimeClientSession.cs (2)

148public async IAsyncEnumerable<RealtimeServerMessage> GetStreamingResponseAsync( 159await foreach (var message in _innerSession.GetStreamingResponseAsync(cancellationToken).ConfigureAwait(false))

Realtime\LoggingRealtimeClientSession.cs (4)

115public async IAsyncEnumerable<RealtimeServerMessage> GetStreamingResponseAsync( 123IAsyncEnumerator<RealtimeServerMessage> e; 141RealtimeServerMessage? message = null; 210private string GetLoggableString(RealtimeServerMessage message)

Realtime\OpenTelemetryRealtimeClientSession.cs (5)

196public async IAsyncEnumerable<RealtimeServerMessage> GetStreamingResponseAsync( 212IAsyncEnumerable<RealtimeServerMessage> responses; 233RealtimeServerMessage message; 323private static string? GetOutputModality(RealtimeServerMessage message) 414private RealtimeOtelMessage? ExtractServerOtelMessage(RealtimeServerMessage message)

Microsoft.Extensions.AI.Abstractions (2)

Realtime\ErrorRealtimeServerMessage.cs (1)

35/// Unlike <see cref="RealtimeServerMessage.MessageId"/>, which identifies this server message itself,

Realtime\IRealtimeClientSession.cs (1)

50IAsyncEnumerable<RealtimeServerMessage> GetStreamingResponseAsync(

Microsoft.Extensions.AI.Abstractions.Tests (10)

Realtime\RealtimeServerMessageTests.cs (7)

16var message = new RealtimeServerMessage(); 27var message = new RealtimeServerMessage 71Assert.IsAssignableFrom<RealtimeServerMessage>(message); 117Assert.IsAssignableFrom<RealtimeServerMessage>(message); 159Assert.IsAssignableFrom<RealtimeServerMessage>(message); 224Assert.IsAssignableFrom<RealtimeServerMessage>(message); 260Assert.IsAssignableFrom<RealtimeServerMessage>(message);

TestRealtimeClientSession.cs (3)

18public Func<CancellationToken, IAsyncEnumerable<RealtimeServerMessage>>? GetStreamingResponseAsyncCallback { get; set; } 33public IAsyncEnumerable<RealtimeServerMessage> GetStreamingResponseAsync( 57private static async IAsyncEnumerable<RealtimeServerMessage> EmptyAsyncEnumerable()

Microsoft.Extensions.AI.OpenAI (4)

OpenAIRealtimeClientSession.cs (4)

158public async IAsyncEnumerable<RealtimeServerMessage> GetStreamingResponseAsync( 168var serverMessage = MapServerUpdate(update); 750private RealtimeServerMessage? MapServerUpdate(Sdk.RealtimeServerUpdate update) => update switch 838private RealtimeServerMessage HandleSessionEvent(Sdk.RealtimeSession? session, Sdk.RealtimeServerUpdate update)

Microsoft.Extensions.AI.Tests (61)

Realtime\FunctionInvokingRealtimeClientTests.cs (25)

64var serverMessages = new RealtimeServerMessage[] 77var received = new List<RealtimeServerMessage>(); 78await foreach (var msg in session.GetStreamingResponseAsync()) 114var received = new List<RealtimeServerMessage>(); 115await foreach (var msg in session.GetStreamingResponseAsync()) 164await foreach (var msg in session.GetStreamingResponseAsync()) 188var messages = Enumerable.Range(0, 5).Select<int, RealtimeServerMessage>(i => 202var received = new List<RealtimeServerMessage>(); 203await foreach (var msg in session.GetStreamingResponseAsync()) 242await foreach (var msg in session.GetStreamingResponseAsync()) 270await foreach (var msg in session.GetStreamingResponseAsync()) 309await foreach (var msg in session.GetStreamingResponseAsync()) 347await foreach (var msg in session.GetStreamingResponseAsync()) 392var received = new List<RealtimeServerMessage>(); 393await foreach (var msg in session.GetStreamingResponseAsync()) 426var received = new List<RealtimeServerMessage>(); 427await foreach (var msg in session.GetStreamingResponseAsync()) 503await foreach (var msg in session.GetStreamingResponseAsync()) 526var messages = new List<RealtimeServerMessage> 548await foreach (var msg in session.GetStreamingResponseAsync()) 615var received = new List<RealtimeServerMessage>(); 616await foreach (var msg in session.GetStreamingResponseAsync()) 652private static async IAsyncEnumerable<RealtimeServerMessage> YieldMessages( 653IList<RealtimeServerMessage> messages, 657foreach (var msg in messages)

Realtime\LoggingRealtimeClientTests.cs (6)

163static async IAsyncEnumerable<RealtimeServerMessage> GetMessagesAsync() 177await foreach (var message in session.GetStreamingResponseAsync()) 279static async IAsyncEnumerable<RealtimeServerMessage> ThrowCancellationAsync([EnumeratorCancellation] CancellationToken cancellationToken) 298await foreach (var message in session.GetStreamingResponseAsync(cts.Token)) 321static async IAsyncEnumerable<RealtimeServerMessage> ThrowErrorAsync() 339await foreach (var message in session.GetStreamingResponseAsync())

Realtime\OpenTelemetryRealtimeClientTests.cs (27)

51static async IAsyncEnumerable<RealtimeServerMessage> CallbackAsync([EnumeratorCancellation] CancellationToken cancellationToken) 91await foreach (var response in session.GetStreamingResponseAsync()) 214static async IAsyncEnumerable<RealtimeServerMessage> ThrowingCallbackAsync([EnumeratorCancellation] CancellationToken cancellationToken) 231await foreach (var response in session.GetStreamingResponseAsync()) 266static async IAsyncEnumerable<RealtimeServerMessage> ErrorResponseCallbackAsync([EnumeratorCancellation] CancellationToken cancellationToken) 291await foreach (var response in session.GetStreamingResponseAsync()) 317static async IAsyncEnumerable<RealtimeServerMessage> EmptyCallbackAsync([EnumeratorCancellation] CancellationToken cancellationToken) 336await foreach (var response in session.GetStreamingResponseAsync()) 408static async IAsyncEnumerable<RealtimeServerMessage> TranscriptionCallbackAsync([EnumeratorCancellation] CancellationToken cancellationToken) 432await foreach (var response in session.GetStreamingResponseAsync()) 469await foreach (var response in session.GetStreamingResponseAsync()) 512await foreach (var response in session.GetStreamingResponseAsync()) 555await foreach (var response in session.GetStreamingResponseAsync()) 566private static async IAsyncEnumerable<RealtimeServerMessage> SimpleCallbackAsync([EnumeratorCancellation] CancellationToken cancellationToken) 595private static async IAsyncEnumerable<RealtimeServerMessage> CallbackWithToolCallAsync([EnumeratorCancellation] CancellationToken cancellationToken) 640await foreach (var response in session.GetStreamingResponseAsync()) 683await foreach (var response in session.GetStreamingResponseAsync()) 726await foreach (var response in session.GetStreamingResponseAsync()) 768await foreach (var response in session.GetStreamingResponseAsync()) 810await foreach (var response in session.GetStreamingResponseAsync()) 851await foreach (var response in session.GetStreamingResponseAsync()) 892await foreach (var response in session.GetStreamingResponseAsync()) 933await foreach (var response in session.GetStreamingResponseAsync()) 974await foreach (var response in session.GetStreamingResponseAsync()) 1026private static async IAsyncEnumerable<RealtimeServerMessage> CallbackWithTextOutputAsync([EnumeratorCancellation] CancellationToken cancellationToken) 1038private static async IAsyncEnumerable<RealtimeServerMessage> CallbackWithTranscriptionAsync([EnumeratorCancellation] CancellationToken cancellationToken) 1050private static async IAsyncEnumerable<RealtimeServerMessage> CallbackWithServerErrorAsync([EnumeratorCancellation] CancellationToken cancellationToken)

test\Libraries\Microsoft.Extensions.AI.Abstractions.Tests\TestRealtimeClientSession.cs (3)

18public Func<CancellationToken, IAsyncEnumerable<RealtimeServerMessage>>? GetStreamingResponseAsyncCallback { get; set; } 33public IAsyncEnumerable<RealtimeServerMessage> GetStreamingResponseAsync( 57private static async IAsyncEnumerable<RealtimeServerMessage> EmptyAsyncEnumerable()