db.cs 683 B

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