Expand description
Async (tokio) io, written in fsm style
IO ops are written as async state machines that thread the state through the futures to avoid being encumbered by lifetimes.
This makes them occasionally a bit verbose to use, but allows being generic without having to box the futures.
Structs
- Response decoder state machine, after reading the size
- Response decoder state machine, at the start of a stream
Enums
- Next type for ResponseDecoderReading.
Functions
- Encode ranges relevant to a query from a reader and outboard to a writer
- Encode ranges relevant to a query from a reader and outboard to a writer