Feature/v1.0.0

AspNetCore.Sequence/CHANGELOG.md

@@ -0,0 +1,38 @@
+# Changelog — Juner.AspNetCore.Sequence
+
+## [1.0.0] — 2026-03-31
+
+### Added
+
+- Initial release of ASP.NET Core integration for streaming JSON.
+- Streaming **output** via:
+  - `JsonSequenceResult<T>`
+  - `JsonLineResult<T>`
+  - `NdJsonResult<T>`
+  - `SequenceResult<T>` (content negotiation)
+- Streaming **input** via:
+  - `Sequence<T>` (Minimal API model binding)
+  - MVC `SequenceInputFormatter`
+- Streaming **output** for MVC via:
+  - `JsonSequenceOutputFormatter`
+  - `JsonLineOutputFormatter`
+  - `NdJsonOutputFormatter`
+- Content negotiation for streaming formats (`Accept` header).
+- OpenAPI (.NET 10+) support:
+  - `x-streaming: true`
+  - `x-itemSchema`
+  - Per‑format content types
+- Minimal API integration:
+  - `TypedResults.JsonSequence`
+  - `TypedResults.JsonLine`
+  - `TypedResults.NdJson`
+  - `TypedResults.Sequence`
+- MVC integration:
+  - `[Consumes]` / `[Produces]` metadata for streaming formats
+  - Controller binding for `Sequence<T>`
+
+### Notes
+
+- Minimal API streaming is **AOT‑safe**.
+- MVC streaming uses formatters and is **not AOT‑safe** due to ASP.NET Core limitations.
+- JSON Array (`application/json`) is accepted/returned only as a **non‑streaming convenience**.

AspNetCore.Sequence/Http/Content.cs

@@ -5,4 +5,4 @@ namespace Juner.AspNetCore.Sequence.Http;
 /// </summary>
 /// <param name="ContentType"></param>
 /// <param name="IsStreaming"></param>
-public record Content(string ContentType, bool IsStreaming) : IContent;
+public record Content(string ContentType, bool IsStreaming, Type? NoStreamingType = null) : IContent;

AspNetCore.Sequence/Http/HttpResults/JsonLineResultOfT.cs

@@ -2,6 +2,9 @@
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Http.Metadata;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Logging.Abstractions;
 using System.Reflection;
 using System.Threading.Channels;
 
@@ -58,4 +61,6 @@ public static void PopulateMetadata(MethodInfo method, EndpointBuilder builder)
             typeof(T),
             [new Content(CONTENT_TYPE, true)]));
     }
+
+    protected override ILogger GetLogger(IServiceProvider provider) => provider.GetService<ILogger<JsonLineResult<T>>>() ?? (ILogger)NullLogger.Instance;
 }

AspNetCore.Sequence/Http/HttpResults/JsonSequenceResultOfT.cs

@@ -2,6 +2,9 @@
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Http.Metadata;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Logging.Abstractions;
 using System.Reflection;
 using System.Threading.Channels;
 
@@ -63,4 +66,5 @@ public static void PopulateMetadata(MethodInfo method, EndpointBuilder builder)
             typeof(T),
             [new Content(CONTENT_TYPE, true)]));
     }
+    protected override ILogger GetLogger(IServiceProvider provider) => provider.GetService<ILogger<JsonSequenceResult<T>>>() ?? (ILogger)NullLogger.Instance;
 }

AspNetCore.Sequence/Http/HttpResults/NdJsonResultOfT.cs

@@ -2,6 +2,9 @@
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Http.Metadata;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Logging.Abstractions;
 using System.Reflection;
 using System.Threading.Channels;
 
@@ -57,4 +60,5 @@ public static void PopulateMetadata(MethodInfo method, EndpointBuilder builder)
             typeof(T),
             [new Content(CONTENT_TYPE, true)]));
     }
+    protected override ILogger GetLogger(IServiceProvider provider) => provider.GetService<ILogger<NdJsonResult<T>>>() ?? (ILogger)NullLogger.Instance;
 }

AspNetCore.Sequence/Http/HttpResults/SequenceResultBaseOfT.ExecuteAsync.cs

@@ -4,7 +4,6 @@
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
-using Microsoft.Extensions.Logging.Abstractions;
 using System.Text.Json;
 using System.Diagnostics;
 using Juner.Sequence;
@@ -19,13 +18,7 @@ namespace Juner.AspNetCore.Sequence.Http.HttpResults;
 [DebuggerDisplay("{Values,nq}")]
 public abstract partial class SequenceResultBase<T> : IResult
 {
-    ILogger GetLogger(IServiceProvider provider)
-    {
-        var loggerType = typeof(ILogger<>).MakeGenericType(GetType());
-        var logger = provider.GetService(loggerType) as ILogger;
-        if (logger is not null) return logger;
-        return NullLogger.Instance;
-    }
+    protected abstract ILogger GetLogger(IServiceProvider provider);
     static JsonSerializerOptions GetOptions(IServiceProvider provider, ILogger logger)
     {
         var jsonOptions = provider.GetService<IOptions<JsonOptions>>()?.Value;

AspNetCore.Sequence/Http/HttpResults/SequenceResultOfT.ExecuteAsync.cs

@@ -6,9 +6,7 @@
 using Microsoft.Extensions.Logging.Abstractions;
 using Microsoft.Extensions.Options;
 using System.Diagnostics;
-using System.Text;
 using System.Text.Json;
-using System.Net.Mime;
 using Juner.Sequence;
 
 #if !NET8_0_OR_GREATER
@@ -20,13 +18,7 @@ namespace Juner.AspNetCore.Sequence.Http.HttpResults;
 [DebuggerDisplay("{Values,nq}")]
 public partial class SequenceResult<T> : IResult
 {
-    ILogger GetLogger(IServiceProvider provider)
-    {
-        var loggerType = typeof(ILogger<>).MakeGenericType(GetType());
-        var logger = provider.GetService(loggerType) as ILogger;
-        if (logger is not null) return logger;
-        return NullLogger.Instance;
-    }
+    ILogger GetLogger(IServiceProvider provider) => provider.GetService<ILogger<SequenceResult<T>>>() ?? (ILogger)NullLogger.Instance;
     JsonSerializerOptions GetOptions(IServiceProvider provider, ILogger logger)
     {
         var jsonOptions = provider.GetService<IOptions<JsonOptions>>()?.Value;
@@ -60,7 +52,7 @@ public async Task ExecuteAsync(HttpContext httpContext)
 #endif
         var values = ToAsyncEnumerable(httpContext.RequestAborted);
 
-        if (options.IsEmpty)
+        if (options.IsInvalid)
         {
             var jsonTypeInfo = serializerOptions.GetTypeInfo<IAsyncEnumerable<T>>();
 

AspNetCore.Sequence/Http/HttpResults/SequenceResultOfT.cs

@@ -113,7 +113,7 @@ public static void PopulateMetadata(MethodInfo method, EndpointBuilder builder)
         builder.Metadata.Add(new ProducesSequenceResponseTypeMetadata(
             STATUS_CODE,
             typeof(T),
-            [.. MakePatternList.Select(v => new Content(v.ContentType, v.IsStreaming))]));
+            [.. MakePatternList.Select(v => new Content(v.ContentType, v.IsStreaming, v.IsStreaming ? null : typeof(IAsyncEnumerable<T>)))]));
     }
 
     record MakePattern(string ContentType, ISequenceSerializerWriteOptions Options, bool IsStreaming);
@@ -189,7 +189,7 @@ static IEnumerable<MakePattern> MakePatterns()
         {
             const string contentType =
                 "application/json";
-            yield return new(contentType, SequenceSerializerOptions.Empty, false);
+            yield return new(contentType, SequenceSerializerOptions.Default, false);
         }
 
     }

AspNetCore.Sequence/Http/IContent.cs

@@ -4,4 +4,5 @@ public interface IContent
 {
     string ContentType { get; }
     bool IsStreaming { get; }
+    Type? NoStreamingType { get; }
 }

AspNetCore.Sequence/Http/SequenceOfT.PopulateMetadata.cs

@@ -9,7 +9,7 @@ public sealed partial class Sequence<T> : IEndpointParameterMetadataProvider
     public static void PopulateMetadata(ParameterInfo parameter, EndpointBuilder builder)
      => builder.Metadata.Add(new AcceptsSequenceMetadata(
             itemType: typeof(T),
-            contentTypes: [.. MakePatternActionList.Select(v => new Content(v.ContentType, v.IsStreaming))],
+            contentTypes: [.. MakePatternActionList.Select(v => new Content(v.ContentType, v.IsStreaming, v.IsStreaming ? null : typeof(IAsyncEnumerable<T>)))],
             isOptional: false
         ));
 }

AspNetCore.Sequence/Http/SequenceOfT.cs

@@ -1,6 +1,5 @@
 using Microsoft.AspNetCore.Http.Metadata;
 using Microsoft.Extensions.Logging;
-using System.Runtime.CompilerServices;
 using System.Threading.Channels;
 
 namespace Juner.AspNetCore.Sequence.Http;

AspNetCore.Sequence/Internals/InternalFormatReader.cs

@@ -1,5 +1,6 @@
 using Juner.Sequence;
 using System.Collections.Concurrent;
+using System.Diagnostics.CodeAnalysis;
 using System.IO.Pipelines;
 using System.Text.Json.Serialization.Metadata;
 using System.Threading.Channels;
@@ -29,6 +30,8 @@ public static object ReadResult<T>(
         };
     }
 
+    [RequiresDynamicCode("Uses dynamic generic delegate generation")]
+    [RequiresUnreferencedCode("Uses reflection to create generic methods")]
     public static object ReadResult(
         Type elementType,
         EnumerableType enumerableType,
@@ -59,6 +62,8 @@ CancellationToken cancellationToken
 
     static readonly ConcurrentDictionary<Type, Delegate> cache = new();
 
+    [RequiresDynamicCode("Uses dynamic generic delegate generation")]
+    [RequiresUnreferencedCode("Uses reflection to create generic methods")]
     static Delegate CreateDelegate(Type elementType)
     {
         var method =

AspNetCore.Sequence/Internals/InternalFormatWriter.cs

@@ -11,10 +11,6 @@
 using System.Text.Json.Serialization.Metadata;
 using System.Threading.Channels;
 
-#if NET9_0_OR_GREATER
-using System.IO.Pipelines;
-#endif
-
 namespace Juner.AspNetCore.Sequence.Internals;
 
 internal static class InternalFormatWriter
@@ -27,6 +23,8 @@ internal static class InternalFormatWriter
         {typeof(ChannelReader<>), EnumerableType.ChannelReader },
         {typeof(Http.Sequence<>), EnumerableType.Sequence },
     }.AsReadOnly();
+
+    [RequiresUnreferencedCode("Uses reflection to search interfaces")]
     public static bool TryGetOutputMode([NotNullWhen(true)] Type? objectType, [NotNullWhen(true)] out EnumerableType outputType, [NotNullWhen(true)] out Type type)
     {
         outputType = default;
@@ -54,6 +52,9 @@ public static bool TryGetOutputMode([NotNullWhen(true)] Type? objectType, [NotNu
     }
 
     static JsonTypeInfo GetJsonTypeInfo(JsonSerializerOptions serializerOptions, Type type) => serializerOptions.GetTypeInfo(type);
+
+    [RequiresDynamicCode("Uses dynamic generic delegate generation")]
+    [RequiresUnreferencedCode("Uses reflection to create generic methods")]
     public static Task WriteResponseBodyAsync(
         Type? objectType,
         object? @object,
@@ -75,6 +76,7 @@ public static Task WriteResponseBodyAsync(
             cancellationToken);
     }
 
+    [RequiresUnreferencedCode("Uses reflection to search interfaces")]
     public static Task WriteAsync<Enumerable, T>(
         Enumerable? @object,
         HttpContext httpContext,
@@ -117,6 +119,8 @@ static async IAsyncEnumerable<T> ToAsyncEnumerable<T>(IEnumerable<T>? values, [E
 
     static readonly ConcurrentDictionary<Type, Delegate> cache = new();
 
+    [RequiresDynamicCode("Uses dynamic generic delegate generation")]
+    [RequiresUnreferencedCode("Uses reflection to create generic methods")]
     static Task WriteAsync(
         Type objectType,
         object? @object,
@@ -147,6 +151,8 @@ static Task WriteAsync(
             cancellationToken);
     }
 
+    [RequiresDynamicCode("Uses dynamic generic delegate generation")]
+    [RequiresUnreferencedCode("Uses reflection to create generic methods")]
     static Delegate CreateDelegate(Type objectType)
     {
         if (!TryGetOutputMode(objectType, out _, out var type))

AspNetCore.Sequence/Juner.AspNetCore.Sequence.csproj

@@ -1,8 +1,8 @@
 <Project Sdk="Microsoft.NET.Sdk">
-
   <PropertyGroup>
-    <Description>Streaming JSON sequence support for ASP.NET Core.
-Supports NDJSON, JSON Lines, JSON Sequence, and JSON arrays using IAsyncEnumerable.</Description>
+    <Description>Streaming JSON support for ASP.NET Core (NDJSON, JSON Lines, JSON Sequence).
+Also supports JSON arrays as non-streaming input/output for convenience.
+Provides Minimal API and MVC integration with content negotiation and OpenAPI support.</Description>
     <PackageTags>aspnetcore;streaming;json;ndjson;jsonlines;json-seq;iasyncenumerable</PackageTags>
     <PackageProjectUrl>https://github.com/juner/Sequence</PackageProjectUrl>
     <IsPackable>True</IsPackable>

AspNetCore.Sequence/Mvc/Formatters/JsonLineOutputFormatter.cs

@@ -9,6 +9,8 @@
 using System.Text;
 using System.Text.Json;
 using Juner.Sequence;
+using System.Diagnostics.CodeAnalysis;
+
 
 
 #if NET8_0_OR_GREATER
@@ -22,6 +24,8 @@ namespace Juner.AspNetCore.Sequence.Mvc.Formatters;
 /// <summary>
 /// application/jsonl 対応の フォーマッター
 /// </summary>
+[RequiresDynamicCode("Uses dynamic generic delegate generation")]
+[RequiresUnreferencedCode("Uses reflection to create generic methods")]
 public partial class JsonLineOutputFormatter : TextOutputFormatter
 {
     /// <summary>
@@ -37,7 +41,7 @@ public JsonLineOutputFormatter()
     const string ContentType =
         "application/jsonl";
 
-    /// <inheritdoc />
+    /// <inheritdoc />    
     protected override bool CanWriteType(Type? type)
       => InternalFormatWriter.TryGetOutputMode(type, out _, out _);
 

AspNetCore.Sequence/Mvc/Formatters/JsonSequenceOutputFormatter.cs

@@ -9,6 +9,8 @@
 using System.Text;
 using System.Text.Json;
 using Juner.Sequence;
+using System.Diagnostics.CodeAnalysis;
+
 
 
 #if NET8_0_OR_GREATER
@@ -22,6 +24,8 @@ namespace Juner.AspNetCore.Sequence.Mvc.Formatters;
 /// <summary>
 /// application/json-seq 対応の フォーマッター
 /// </summary>
+[RequiresDynamicCode("Uses dynamic generic delegate generation")]
+[RequiresUnreferencedCode("Uses reflection to create generic methods")]
 public partial class JsonSequenceOutputFormatter : TextOutputFormatter
 {
     /// <summary>

AspNetCore.Sequence/Mvc/Formatters/NdJsonOutputFormatter.cs

@@ -9,6 +9,8 @@
 using System.Text;
 using System.Text.Json;
 using Juner.Sequence;
+using System.Diagnostics.CodeAnalysis;
+
 
 
 #if NET8_0_OR_GREATER
@@ -22,6 +24,8 @@ namespace Juner.AspNetCore.Sequence.Mvc.Formatters;
 /// <summary>
 /// application/x-ndjson 対応の フォーマッター
 /// </summary>
+[RequiresDynamicCode("Uses dynamic generic delegate generation")]
+[RequiresUnreferencedCode("Uses reflection to create generic methods")]
 public partial class NdJsonOutputFormatter : TextOutputFormatter
 {
     /// <summary>

AspNetCore.Sequence/Mvc/Formatters/SequenceInputFormatter.cs

@@ -11,11 +11,15 @@
 using System.Diagnostics.CodeAnalysis;
 using System.Text;
 using System.Text.Json;
-using System.Text.Json.Serialization.Metadata;
 using System.Threading.Channels;
+#if !NET8_0_OR_GREATER
+using System.Text.Json.Serialization.Metadata;
+#endif
 
 namespace Juner.AspNetCore.Sequence.Mvc.Formatters;
 
+[RequiresDynamicCode("Uses dynamic generic delegate generation")]
+[RequiresUnreferencedCode("Uses reflection to create generic methods")]
 public partial class SequenceInputFormatter : TextInputFormatter
 {
 
@@ -58,13 +62,7 @@ public override bool CanRead(InputFormatterContext context)
         return true;
     }
 
-    ILogger GetLogger(IServiceProvider provider)
-    {
-        var loggerType = typeof(ILogger<>).MakeGenericType(GetType());
-        var logger = provider.GetService(loggerType) as ILogger;
-        if (logger is not null) return logger;
-        return NullLogger.Instance;
-    }
+    ILogger GetLogger(IServiceProvider provider) => provider.GetService<ILogger<SequenceInputFormatter>>() ?? (ILogger)NullLogger.Instance;
     static JsonSerializerOptions GetOptions(IServiceProvider provider, ILogger logger)
     {
         var jsonOptions = provider.GetService<IOptions<JsonOptions>>()?.Value;