18 references to Reader
Aspire.Hosting.Native.Core.AotSmoke (3)
tests\Aspire.Hosting.Native.Core.Tests\TestServices\DiagnosticCapture.cs (3)
65while (_subscription.Reader.TryRead(out var value)) 72if (_subscription.Reader.Completion.IsCompleted) 74_subscription.Reader.Completion.GetAwaiter().GetResult();
Aspire.Hosting.Native.Core.Tests (14)
NativeDiagnosticChannelTests.cs (11)
20Assert.Equal(first, await fast.Reader.ReadAsync(TestContext.Current.CancellationToken)); 22Assert.Equal(second, await fast.Reader.ReadAsync(TestContext.Current.CancellationToken)); 23Assert.Equal(first, await slow.Reader.ReadAsync(TestContext.Current.CancellationToken)); 24await Assert.ThrowsAsync<DiagnosticOverflowException>(() => slow.Reader.Completion); 26Assert.Equal(first, await fast.Reader.ReadAsync(TestContext.Current.CancellationToken)); 38Assert.Equal(operation, await first.Reader.ReadAsync(TestContext.Current.CancellationToken)); 39await first.Reader.Completion; 40Assert.Equal(operation, await second.Reader.ReadAsync(TestContext.Current.CancellationToken)); 42await second.Reader.Completion; 52var awaited = subscription.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask(); 68await subscription.Reader.Completion;
TestServices\DiagnosticCapture.cs (3)
65while (_subscription.Reader.TryRead(out var value)) 72if (_subscription.Reader.Completion.IsCompleted) 74_subscription.Reader.Completion.GetAwaiter().GetResult();
Aspire.Hosting.Native.Server (1)
NativeDiagnosticPump.cs (1)
24await foreach (var operation in _subscription.Reader.ReadAllAsync().ConfigureAwait(false))