Module bao_tree::io::fsm

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

• Handle
  Convenience wrapper around a type that implements a state passing style fsm.
• ResponseDecoderReading
  Response decoder state machine, after reading the size
• ResponseDecoderStart
  Response decoder state machine, at the start of a stream
• SyncIoAdapter
• UnwrapJoinHandle

Enums

• ResponseDecoderReadingNext
  Next type for ResponseDecoderReading.

Traits

• AsyncSliceReader
  A reader that can read a slice at a specified offset
• AsyncSliceWriter
  A writer that can write a slice at a specified offset

Functions

• encode_ranges
  Encode ranges relevant to a query from a reader and outboard to a writer
• encode_ranges_validated
  Encode ranges relevant to a query from a reader and outboard to a writer