Expand description
Async split sender/receiver connection. Inspired by hsqlx’s PgWire.Async architecture.
A single TCP connection is shared by many concurrent handler tasks. The writer task coalesces messages from multiple requests into one write(). The reader task parses responses and dispatches them to waiting handlers via FIFO.
Structs§
- Async
Conn - A shared async connection that multiplexes requests from many tasks.
- Stream
Header - Metadata sent at the start of a streaming response.
Enums§
- Pipeline
Response - Response from a pipeline request.
- Response
Collector - How to collect response messages for a request.
Type Aliases§
- Streamed
Row - A single streamed row.