2 instantiations of SseItem
Shared (2)
ServerSentEvents\SseParser_1.cs (2)
344sseItem = new SseItem<T>(data, _eventType) { EventId = _eventId, ReconnectionInterval = _nextReconnectionInterval }; 398sseItem = new SseItem<T>(data, _eventType) { EventId = _eventId, ReconnectionInterval = _nextReconnectionInterval };
15 references to SseItem
Shared (15)
ServerSentEvents\SseFormatter.cs (6)
30public static Task WriteAsync(IAsyncEnumerable<SseItem<string>> source, Stream destination, CancellationToken cancellationToken = default) 54public static Task WriteAsync<T>(IAsyncEnumerable<SseItem<T>> source, Stream destination, Action<SseItem<T>, IBufferWriter<byte>> itemFormatter, CancellationToken cancellationToken = default) 74private static async Task WriteAsyncCore<T>(IAsyncEnumerable<SseItem<T>> source, Stream destination, Action<SseItem<T>, IBufferWriter<byte>> itemFormatter, CancellationToken cancellationToken) 79await foreach (SseItem<T> item in source.WithCancellation(cancellationToken).ConfigureAwait(false))
ServerSentEvents\SseItem.cs (1)
26/// <summary>Initializes a new instance of the <see cref="SseItem{T}"/> struct.</summary>
ServerSentEvents\SseParser.cs (3)
15/// <summary>The default <see cref="SseItem{T}.EventType"/> ("message") for an event that did not explicitly specify a type.</summary> 18/// <summary>Creates a parser for parsing a <paramref name="sseStream"/> of server-sent events into a sequence of <see cref="SseItem{String}"/> values.</summary> 32/// <summary>Creates a parser for parsing a <paramref name="sseStream"/> of server-sent events into a sequence of <see cref="SseItem{T}"/> values.</summary>
ServerSentEvents\SseParser_1.cs (5)
112public IEnumerable<SseItem<T>> Enumerate() 147if (ProcessLine(out SseItem<T> sseItem, out int advance)) 192public async IAsyncEnumerable<SseItem<T>> EnumerateAsync([EnumeratorCancellation] CancellationToken cancellationToken = default) 227if (ProcessLine(out SseItem<T> sseItem, out int advance)) 332private bool ProcessLine(out SseItem<T> sseItem, out int advance)