1 write to _extensionTaskChannel
aspire (1)
Interaction\ExtensionInteractionService.cs (1)
42
_extensionTaskChannel
= Channel.CreateUnbounded<Func<Task>>(new UnboundedChannelOptions
25 references to _extensionTaskChannel
aspire (25)
Interaction\ExtensionInteractionService.cs (25)
50
while (await
_extensionTaskChannel
.Reader.WaitToReadAsync().ConfigureAwait(false))
54
var taskFunction = await
_extensionTaskChannel
.Reader.ReadAsync().ConfigureAwait(false);
68
var result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.ShowStatusAsync(statusText.RemoveSpectreFormatting(), _cancellationToken));
72
result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.ShowStatusAsync(null, _cancellationToken));
79
var result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.ShowStatusAsync(statusText.RemoveSpectreFormatting(), _cancellationToken));
83
result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.ShowStatusAsync(null, _cancellationToken));
93
await
_extensionTaskChannel
.Writer.WriteAsync(async () =>
141
await
_extensionTaskChannel
.Writer.WriteAsync(async () =>
170
await
_extensionTaskChannel
.Writer.WriteAsync(async () =>
199
await
_extensionTaskChannel
.Writer.WriteAsync(async () =>
223
var result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.DisplayIncompatibleVersionErrorAsync(ex.RequiredCapability, appHostHostingSdkVersion, _cancellationToken));
231
var result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.DisplayErrorAsync(errorMessage.RemoveSpectreFormatting(), _cancellationToken));
238
var result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.DisplayMessageAsync(emoji, message.RemoveSpectreFormatting(), _cancellationToken));
245
var result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.DisplaySuccessAsync(message.RemoveSpectreFormatting(), _cancellationToken));
252
var result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.DisplaySubtleMessageAsync(message.RemoveSpectreFormatting(), _cancellationToken));
264
var result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.DisplayDashboardUrlsAsync(dashboardUrls, _cancellationToken));
270
var result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.DisplayLinesAsync(lines.Select(line => new DisplayLineState(line.Stream.RemoveSpectreFormatting(), line.Line.RemoveSpectreFormatting())), _cancellationToken));
277
var result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.DisplayCancellationMessageAsync(_cancellationToken));
284
var result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.DisplayEmptyLineAsync(_cancellationToken));
291
var result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.OpenEditorAsync(path, _cancellationToken));
297
var result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.DisplayPlainTextAsync(text, _cancellationToken));
306
var result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.LogMessageAsync(LogLevel.Information, markdown, _cancellationToken));
318
var result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.LogMessageAsync(logLevel, message.RemoveSpectreFormatting(), _cancellationToken));
334
var result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.NotifyAppHostStartupCompletedAsync(_cancellationToken));
350
var result =
_extensionTaskChannel
.Writer.TryWrite(() => Backchannel.WriteDebugSessionMessageAsync(message.RemoveSpectreFormatting(), stdout, textStyle, _cancellationToken));