10 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 (9)
Commands\PublishCommandPromptingIntegrationTests.cs (1)
809yield return new PublishingActivity
TestServices\TestAppHostBackchannel.cs (8)
123yield return new PublishingActivity 134yield return new PublishingActivity 145yield return new PublishingActivity 156yield return new PublishingActivity 167yield return new PublishingActivity 178yield return new PublishingActivity 189yield return new PublishingActivity 200yield return new PublishingActivity
87 references to PublishingActivity
aspire (83)
Backchannel\AppHostBackchannel.cs (4)
22IAsyncEnumerable<PublishingActivity> GetPublishingActivitiesAsync(CancellationToken cancellationToken); 152public async IAsyncEnumerable<PublishingActivity> GetPublishingActivitiesAsync([EnumeratorCancellation] CancellationToken cancellationToken) 159var publishingActivities = await rpc.InvokeWithCancellationAsync<IAsyncEnumerable<PublishingActivity>>( 166await foreach (var state in publishingActivities.WithCancellation(cancellationToken))
Backchannel\BackchannelJsonSerializerContext.cs (2)
23[JsonSerializable(typeof(IAsyncEnumerable<PublishingActivity>))] 24[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)
50if (type == typeof(global::Aspire.Cli.Backchannel.PublishingActivity)) 98if (type == typeof(global::StreamJsonRpc.Reflection.MessageFormatterEnumerableTracker.EnumeratorResults<global::Aspire.Cli.Backchannel.PublishingActivity>)) 118if (type == typeof(global::System.Collections.Generic.IAsyncEnumerable<global::Aspire.Cli.Backchannel.PublishingActivity>)) 138if (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)
307public async Task<bool> ProcessPublishingActivitiesDebugAsync(IAsyncEnumerable<PublishingActivity> publishingActivities, IAppHostBackchannel backchannel, CancellationToken cancellationToken) 311PublishingActivity? publishingActivity = null; 313await foreach (var activity in publishingActivities.WithCancellation(cancellationToken)) 414public async Task<bool> ProcessAndDisplayPublishingActivitiesAsync(IAsyncEnumerable<PublishingActivity> publishingActivities, IAppHostBackchannel backchannel, bool isDebugOrTraceLoggingEnabled, CancellationToken cancellationToken) 420PublishingActivity? publishingActivity = null; 424await foreach (var activity in publishingActivities.WithCancellation(cancellationToken)) 671private async Task HandlePromptActivityAsync(PublishingActivity activity, IAppHostBackchannel backchannel, CancellationToken cancellationToken)
Aspire.Cli.Tests (4)
Commands\PublishCommandPromptingIntegrationTests.cs (1)
789public async IAsyncEnumerable<PublishingActivity> GetPublishingActivitiesAsync([EnumeratorCancellation] CancellationToken cancellationToken)
TestServices\TestAppHostBackchannel.cs (3)
28public Func<CancellationToken, IAsyncEnumerable<PublishingActivity>>? GetPublishingActivitiesAsyncCallback { get; set; } 109public async IAsyncEnumerable<PublishingActivity> GetPublishingActivitiesAsync([EnumeratorCancellation]CancellationToken cancellationToken) 116await foreach (var activity in publishingActivities)