15 instantiations of PublishingActivity
aspire (1)
BackchannelJsonSerializerContext.PublishingActivity.g.cs (1)
32ObjectWithParameterizedConstructorCreator = static args => new global::Aspire.Cli.Backchannel.PublishingActivity(){ Type = (string)args[0], Data = (global::Aspire.Cli.Backchannel.PublishingActivityData)args[1] },
Aspire.Cli.Tests (14)
Commands\DeployCommandTests.cs (5)
405yield return new PublishingActivity 418yield return new PublishingActivity 430yield return new PublishingActivity 444yield return new PublishingActivity 457yield return new PublishingActivity
Commands\PublishCommandPromptingIntegrationTests.cs (1)
808yield return new PublishingActivity
TestServices\TestAppHostCliBackchannel.cs (8)
122yield return new PublishingActivity 133yield return new PublishingActivity 144yield return new PublishingActivity 155yield return new PublishingActivity 166yield return new PublishingActivity 177yield return new PublishingActivity 188yield return new PublishingActivity 199yield return new PublishingActivity
88 references to PublishingActivity
aspire (83)
Backchannel\AppHostCliBackchannel.cs (4)
22IAsyncEnumerable<PublishingActivity> GetPublishingActivitiesAsync(CancellationToken cancellationToken); 387public async IAsyncEnumerable<PublishingActivity> GetPublishingActivitiesAsync([EnumeratorCancellation] CancellationToken cancellationToken) 394var publishingActivities = await rpc.InvokeWithCancellationAsync<IAsyncEnumerable<PublishingActivity>>( 401await foreach (var state in publishingActivities.WithCancellation(cancellationToken))
Backchannel\BackchannelJsonSerializerContext.cs (2)
27[JsonSerializable(typeof(IAsyncEnumerable<PublishingActivity>))] 28[JsonSerializable(typeof(MessageFormatterEnumerableTracker.EnumeratorResults<PublishingActivity>))]
BackchannelJsonSerializerContext.EnumeratorResultsPublishingActivity.g.cs (25)
13private global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>>? _EnumeratorResultsPublishingActivity; 19public global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>> EnumeratorResultsPublishingActivity 22get => _EnumeratorResultsPublishingActivity ??= (global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>>)Options.GetTypeInfo(typeof(global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>)); 25private global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>> Create_EnumeratorResultsPublishingActivity(global::System.Text.Json.JsonSerializerOptions options) 27if (!TryGetTypeInfoForRuntimeCustomConverter<global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>>(options, out global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>> jsonTypeInfo)) 29var objectInfo = new global::System.Text.Json.Serialization.Metadata.JsonObjectInfoValues<global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>> 32ObjectWithParameterizedConstructorCreator = static args => new global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>(){ Values = (global::System.Collections.Generic.IReadOnlyList<global::Aspire.Cli.Backchannel.PublishingActivity>)args[0], Finished = (bool)args[1] }, 35ConstructorAttributeProviderFactory = static () => typeof(global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>).GetConstructor(InstanceMemberBindingFlags, binder: null, global::System.Array.Empty<global::System.Type>(), modifiers: null), 39jsonTypeInfo = global::System.Text.Json.Serialization.Metadata.JsonMetadataServices.CreateObjectInfo<global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>>(options, objectInfo); 51var info0 = new global::System.Text.Json.Serialization.Metadata.JsonPropertyInfoValues<global::System.Collections.Generic.IReadOnlyList<global::Aspire.Cli.Backchannel.PublishingActivity>> 56DeclaringType = typeof(global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>), 58Getter = static obj => ((global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>)obj).Values, 66AttributeProviderFactory = static () => typeof(global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>).GetProperty("Values", InstanceMemberBindingFlags, null, typeof(global::System.Collections.Generic.IReadOnlyList<global::Aspire.Cli.Backchannel.PublishingActivity>), global::System.Array.Empty<global::System.Type>(), null), 69properties[0] = global::System.Text.Json.Serialization.Metadata.JsonMetadataServices.CreatePropertyInfo<global::System.Collections.Generic.IReadOnlyList<global::Aspire.Cli.Backchannel.PublishingActivity>>(options, info0); 76DeclaringType = typeof(global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>), 78Getter = static obj => ((global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>)obj).Finished, 86AttributeProviderFactory = static () => typeof(global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>).GetProperty("Finished", InstanceMemberBindingFlags, null, typeof(bool), global::System.Array.Empty<global::System.Type>(), null), 97private void EnumeratorResultsPublishingActivitySerializeHandler(global::System.Text.Json.Utf8JsonWriter writer, global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>? value) 108IReadOnlyListPublishingActivitySerializeHandler(writer, ((global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>)value).Values); 109writer.WriteBoolean(PropName_finished, ((global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>)value).Finished); 119ParameterType = typeof(global::System.Collections.Generic.IReadOnlyList<global::Aspire.Cli.Backchannel.PublishingActivity>),
BackchannelJsonSerializerContext.GetJsonTypeInfo.g.cs (4)
58if (type == typeof(global::Aspire.Cli.Backchannel.PublishingActivity)) 142if (type == typeof(global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>)) 174if (type == typeof(global::System.Collections.Generic.IAsyncEnumerable<global::Aspire.Cli.Backchannel.PublishingActivity>)) 206if (type == typeof(global::System.Collections.Generic.IReadOnlyList<global::Aspire.Cli.Backchannel.PublishingActivity>))
BackchannelJsonSerializerContext.IAsyncEnumerablePublishingActivity.g.cs (10)
13private global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Collections.Generic.IAsyncEnumerable<global::Aspire.Cli.Backchannel.PublishingActivity>>? _IAsyncEnumerablePublishingActivity; 19public global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Collections.Generic.IAsyncEnumerable<global::Aspire.Cli.Backchannel.PublishingActivity>> IAsyncEnumerablePublishingActivity 22get => _IAsyncEnumerablePublishingActivity ??= (global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Collections.Generic.IAsyncEnumerable<global::Aspire.Cli.Backchannel.PublishingActivity>>)Options.GetTypeInfo(typeof(global::System.Collections.Generic.IAsyncEnumerable<global::Aspire.Cli.Backchannel.PublishingActivity>)); 25private global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Collections.Generic.IAsyncEnumerable<global::Aspire.Cli.Backchannel.PublishingActivity>> Create_IAsyncEnumerablePublishingActivity(global::System.Text.Json.JsonSerializerOptions options) 27if (!TryGetTypeInfoForRuntimeCustomConverter<global::System.Collections.Generic.IAsyncEnumerable<global::Aspire.Cli.Backchannel.PublishingActivity>>(options, out global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Collections.Generic.IAsyncEnumerable<global::Aspire.Cli.Backchannel.PublishingActivity>> jsonTypeInfo)) 29var info = new global::System.Text.Json.Serialization.Metadata.JsonCollectionInfoValues<global::System.Collections.Generic.IAsyncEnumerable<global::Aspire.Cli.Backchannel.PublishingActivity>> 35jsonTypeInfo = global::System.Text.Json.Serialization.Metadata.JsonMetadataServices.CreateIAsyncEnumerableInfo<global::System.Collections.Generic.IAsyncEnumerable<global::Aspire.Cli.Backchannel.PublishingActivity>, global::Aspire.Cli.Backchannel.PublishingActivity>(options, info);
BackchannelJsonSerializerContext.IReadOnlyListPublishingActivity.g.cs (12)
13private global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Collections.Generic.IReadOnlyList<global::Aspire.Cli.Backchannel.PublishingActivity>>? _IReadOnlyListPublishingActivity; 19public global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Collections.Generic.IReadOnlyList<global::Aspire.Cli.Backchannel.PublishingActivity>> IReadOnlyListPublishingActivity 22get => _IReadOnlyListPublishingActivity ??= (global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Collections.Generic.IReadOnlyList<global::Aspire.Cli.Backchannel.PublishingActivity>>)Options.GetTypeInfo(typeof(global::System.Collections.Generic.IReadOnlyList<global::Aspire.Cli.Backchannel.PublishingActivity>)); 25private global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Collections.Generic.IReadOnlyList<global::Aspire.Cli.Backchannel.PublishingActivity>> Create_IReadOnlyListPublishingActivity(global::System.Text.Json.JsonSerializerOptions options) 27if (!TryGetTypeInfoForRuntimeCustomConverter<global::System.Collections.Generic.IReadOnlyList<global::Aspire.Cli.Backchannel.PublishingActivity>>(options, out global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Collections.Generic.IReadOnlyList<global::Aspire.Cli.Backchannel.PublishingActivity>> jsonTypeInfo)) 29var info = new global::System.Text.Json.Serialization.Metadata.JsonCollectionInfoValues<global::System.Collections.Generic.IReadOnlyList<global::Aspire.Cli.Backchannel.PublishingActivity>> 35jsonTypeInfo = global::System.Text.Json.Serialization.Metadata.JsonMetadataServices.CreateIEnumerableInfo<global::System.Collections.Generic.IReadOnlyList<global::Aspire.Cli.Backchannel.PublishingActivity>, global::Aspire.Cli.Backchannel.PublishingActivity>(options, info); 45private void IReadOnlyListPublishingActivitySerializeHandler(global::System.Text.Json.Utf8JsonWriter writer, global::System.Collections.Generic.IReadOnlyList<global::Aspire.Cli.Backchannel.PublishingActivity>? value) 55foreach (global::Aspire.Cli.Backchannel.PublishingActivity element in value)
BackchannelJsonSerializerContext.PublishingActivity.g.cs (19)
13private global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::Aspire.Cli.Backchannel.PublishingActivity>? _PublishingActivity; 19public global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::Aspire.Cli.Backchannel.PublishingActivity> PublishingActivity 22get => _PublishingActivity ??= (global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::Aspire.Cli.Backchannel.PublishingActivity>)Options.GetTypeInfo(typeof(global::Aspire.Cli.Backchannel.PublishingActivity)); 25private global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::Aspire.Cli.Backchannel.PublishingActivity> Create_PublishingActivity(global::System.Text.Json.JsonSerializerOptions options) 27if (!TryGetTypeInfoForRuntimeCustomConverter<global::Aspire.Cli.Backchannel.PublishingActivity>(options, out global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::Aspire.Cli.Backchannel.PublishingActivity> jsonTypeInfo)) 29var objectInfo = new global::System.Text.Json.Serialization.Metadata.JsonObjectInfoValues<global::Aspire.Cli.Backchannel.PublishingActivity> 35ConstructorAttributeProviderFactory = static () => typeof(global::Aspire.Cli.Backchannel.PublishingActivity).GetConstructor(InstanceMemberBindingFlags, binder: null, global::System.Array.Empty<global::System.Type>(), modifiers: null), 39jsonTypeInfo = global::System.Text.Json.Serialization.Metadata.JsonMetadataServices.CreateObjectInfo<global::Aspire.Cli.Backchannel.PublishingActivity>(options, objectInfo); 56DeclaringType = typeof(global::Aspire.Cli.Backchannel.PublishingActivity), 58Getter = static obj => ((global::Aspire.Cli.Backchannel.PublishingActivity)obj).Type, 66AttributeProviderFactory = static () => typeof(global::Aspire.Cli.Backchannel.PublishingActivity).GetProperty("Type", InstanceMemberBindingFlags, null, typeof(string), global::System.Array.Empty<global::System.Type>(), null), 79DeclaringType = typeof(global::Aspire.Cli.Backchannel.PublishingActivity), 81Getter = static obj => ((global::Aspire.Cli.Backchannel.PublishingActivity)obj).Data, 89AttributeProviderFactory = static () => typeof(global::Aspire.Cli.Backchannel.PublishingActivity).GetProperty("Data", InstanceMemberBindingFlags, null, typeof(global::Aspire.Cli.Backchannel.PublishingActivityData), global::System.Array.Empty<global::System.Type>(), null), 102private void PublishingActivitySerializeHandler(global::System.Text.Json.Utf8JsonWriter writer, global::Aspire.Cli.Backchannel.PublishingActivity? value) 112writer.WriteString(PropName_Type, ((global::Aspire.Cli.Backchannel.PublishingActivity)value).Type); 114PublishingActivityDataSerializeHandler(writer, ((global::Aspire.Cli.Backchannel.PublishingActivity)value).Data);
Commands\PipelineCommandBase.cs (7)
315public async Task<bool> ProcessPublishingActivitiesDebugAsync(IAsyncEnumerable<PublishingActivity> publishingActivities, IAppHostCliBackchannel backchannel, CancellationToken cancellationToken) 319PublishingActivity? publishingActivity = null; 321await foreach (var activity in publishingActivities.WithCancellation(cancellationToken)) 422public async Task<bool> ProcessAndDisplayPublishingActivitiesAsync(IAsyncEnumerable<PublishingActivity> publishingActivities, IAppHostCliBackchannel backchannel, bool isDebugOrTraceLoggingEnabled, CancellationToken cancellationToken) 428PublishingActivity? publishingActivity = null; 432await foreach (var activity in publishingActivities.WithCancellation(cancellationToken)) 679private async Task HandlePromptActivityAsync(PublishingActivity activity, IAppHostCliBackchannel backchannel, CancellationToken cancellationToken)
Aspire.Cli.Tests (5)
Commands\DeployCommandTests.cs (1)
402static async IAsyncEnumerable<PublishingActivity> GetFailedDeploymentActivities([EnumeratorCancellation] CancellationToken cancellationToken)
Commands\PublishCommandPromptingIntegrationTests.cs (1)
788public async IAsyncEnumerable<PublishingActivity> GetPublishingActivitiesAsync([EnumeratorCancellation] CancellationToken cancellationToken)
TestServices\TestAppHostCliBackchannel.cs (3)
27public Func<CancellationToken, IAsyncEnumerable<PublishingActivity>>? GetPublishingActivitiesAsyncCallback { get; set; } 108public async IAsyncEnumerable<PublishingActivity> GetPublishingActivitiesAsync([EnumeratorCancellation]CancellationToken cancellationToken) 115await foreach (var activity in publishingActivities)