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

• ResponseDecoderReading
  Response decoder state machine, after reading the size
• ResponseDecoderStart
  Response decoder state machine, at the start of a stream

Enums

• BaoContentItem
  An item of bao content
• ResponseDecoderReadingNext
  Next type for ResponseDecoderReading.

Traits

• AsyncSliceReader
  A trait to abstract async reading from different resource.
• AsyncSliceWriter
  A trait to abstract async writing to different resources.
• Outboard
  A binary merkle tree for blake3 hashes of a blob.
• OutboardMut
  A mutable outboard.

Functions

• decode_response_into
  Decode a response into a file while updating an outboard.
• 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
• valid_ranges
  Given an outboard, return a range set of all valid ranges