json.cs 1.1 KB

1234567891011121314151617181920212223242526272829303132
  1. using BeetleX;
  2. using BeetleX.Buffers;
  3. using SpanJson;
  4. using System;
  5. using System.Collections.Generic;
  6. using System.Text;
  7. using System.Text.Json;
  8. using System.Threading.Tasks;
  9. namespace PlatformBenchmarks
  10. {
  11. public partial class HttpHandler
  12. {
  13. private static readonly JsonSerializerOptions SerializerOptions = new JsonSerializerOptions();
  14. private static Utf8JsonWriter GetUtf8JsonWriter(PipeStream stream, HttpToken token)
  15. {
  16. var buffer = stream.CreateBufferWriter();
  17. var writer = token.Utf8JsonWriter ??= new Utf8JsonWriter(buffer, new JsonWriterOptions { SkipValidation = true });
  18. writer.Reset(buffer);
  19. return writer;
  20. }
  21. public ValueTask Json(PipeStream stream, HttpToken token, ISession session)
  22. {
  23. System.Text.Json.JsonSerializer.Serialize<JsonMessage>(GetUtf8JsonWriter(stream, token), new JsonMessage { message = "Hello, World!" }, SerializerOptions);
  24. OnCompleted(stream, session, token);
  25. return ValueTask.CompletedTask;
  26. }
  27. }
  28. }