db.cs 656 B

12345678910111213141516171819202122232425262728
  1. using SpanJson;
  2. using System;
  3. using System.Threading.Tasks;
  4. using ZYSocket;
  5. using ZYSocket.FiberStream;
  6. namespace PlatformBenchmarks
  7. {
  8. public partial class HttpHandler
  9. {
  10. public async void db(IFiberRw<HttpToken> fiberRw, WriteBytes write)
  11. {
  12. try
  13. {
  14. var data = await fiberRw.UserToken.Db.LoadSingleQueryRow();
  15. await JsonSerializer.NonGeneric.Utf8.SerializeAsync(data, write.Stream);
  16. }
  17. catch (Exception e_)
  18. {
  19. write.Write(e_.Message);
  20. }
  21. OnCompleted(fiberRw, write);
  22. }
  23. }
  24. }