2 instantiations of SseItem
System.Net.ServerSentEvents (2)
System\Net\ServerSentEvents\SseParser_1.cs (2)
327sseItem = new SseItem<T>(data, _eventType) { EventId = _eventId, ReconnectionInterval = _nextReconnectionInterval }; 381sseItem = new SseItem<T>(data, _eventType) { EventId = _eventId, ReconnectionInterval = _nextReconnectionInterval };
15 references to SseItem
Microsoft.AspNetCore.Http.Connections.Client (1)
Internal\ServerSentEventsTransport.cs (1)
140await foreach (var item in parser.EnumerateAsync(cancellationToken).ConfigureAwait(false))
System.Net.ServerSentEvents (14)
System\Net\ServerSentEvents\SseFormatter.cs (6)
27public static Task WriteAsync(IAsyncEnumerable<SseItem<string>> source, Stream destination, CancellationToken cancellationToken = default) 51public static Task WriteAsync<T>(IAsyncEnumerable<SseItem<T>> source, Stream destination, Action<SseItem<T>, IBufferWriter<byte>> itemFormatter, CancellationToken cancellationToken = default) 71private static async Task WriteAsyncCore<T>(IAsyncEnumerable<SseItem<T>> source, Stream destination, Action<SseItem<T>, IBufferWriter<byte>> itemFormatter, CancellationToken cancellationToken) 76await foreach (SseItem<T> item in source.WithCancellation(cancellationToken).ConfigureAwait(false))
System\Net\ServerSentEvents\SseParser.cs (3)
14/// <summary>The default <see cref="SseItem{T}.EventType"/> ("message") for an event that did not explicitly specify a type.</summary> 17/// <summary>Creates a parser for parsing a <paramref name="sseStream"/> of server-sent events into a sequence of <see cref="SseItem{String}"/> values.</summary> 31/// <summary>Creates a parser for parsing a <paramref name="sseStream"/> of server-sent events into a sequence of <see cref="SseItem{T}"/> values.</summary>
System\Net\ServerSentEvents\SseParser_1.cs (5)
96public IEnumerable<SseItem<T>> Enumerate() 131if (ProcessLine(out SseItem<T> sseItem, out int advance)) 176public async IAsyncEnumerable<SseItem<T>> EnumerateAsync([EnumeratorCancellation] CancellationToken cancellationToken = default) 211if (ProcessLine(out SseItem<T> sseItem, out int advance)) 315private bool ProcessLine(out SseItem<T> sseItem, out int advance)